abstract AbstractQueryProcessor<Data, Settings>
Internal
Performs underlying watching and yields a stream of results.
Extends
MetaBaseObserver<WatchedQueryProcessorListener<Data>>
Extended by
Type Parameters
| Type Parameter | Default type |
|---|---|
Data | unknown[] |
Settings extends WatchedQueryOptions | WatchedQueryOptions |
Implements
WatchedQuery<Data,Settings>
Constructors
new AbstractQueryProcessor()
new AbstractQueryProcessor<Data, Settings>(options): AbstractQueryProcessor<Data, Settings>
Parameters
| Parameter | Type |
|---|---|
options | AbstractQueryProcessorOptions<Data, Settings> |
Returns
AbstractQueryProcessor<Data, Settings>
Overrides
MetaBaseObserver<WatchedQueryProcessorListener<Data>>.constructor
Properties
| Property | Modifier | Type | Description |
|---|---|---|---|
state | readonly | WatchedQueryState<Data> | Current state of the watched query. |
Accessors
closed
Get Signature
get closed(): boolean
Returns
boolean
Implementation of
listenerMeta
Get Signature
get listenerMeta(): ListenerMetaManager<Listener>
Returns
ListenerMetaManager<Listener>
Implementation of
Inherited from
MetaBaseObserver.listenerMeta
Methods
close()
close(): Promise<void>
Close the watched query and end all subscriptions.
Returns
Promise<void>
Implementation of
dispose()
dispose(): void
Returns
void
Inherited from
MetaBaseObserver.dispose
iterateAsyncListeners()
iterateAsyncListeners(cb): Promise<void>
Parameters
| Parameter | Type |
|---|---|
cb | (listener) => Promise<any> |
Returns
Promise<void>
Inherited from
MetaBaseObserver.iterateAsyncListeners
iterateListeners()
iterateListeners(cb): void
Parameters
| Parameter | Type |
|---|---|
cb | (listener) => any |
Returns
void
Inherited from
MetaBaseObserver.iterateListeners
registerListener()
registerListener(listener): () => void
Register a listener for updates to the PowerSync client.
Parameters
| Parameter | Type |
|---|---|
listener | Partial<WatchedQueryProcessorListener<Data>> |
Returns
Function
Returns
void
Implementation of
Inherited from
MetaBaseObserver.registerListener
updateSettings()
updateSettings(settings): Promise<void>
Updates the underlying query.
Parameters
| Parameter | Type |
|---|---|
settings | Settings |
Returns
Promise<void>