WebStreamingSyncImplementation

Internal

Extends

• AbstractStreamingSyncImplementation

Extended by

• SharedWebStreamingSyncImplementation

Constructors

new WebStreamingSyncImplementation()

new WebStreamingSyncImplementation(options): WebStreamingSyncImplementation

Parameters

Parameter	Type
options	WebStreamingSyncImplementationOptions

Returns

WebStreamingSyncImplementation

Overrides

AbstractStreamingSyncImplementation.constructor

Properties

Property	Type	Inherited from
syncStatus	SyncStatus	AbstractStreamingSyncImplementation.syncStatus

Accessors

isConnected

Get Signature

get isConnected(): boolean

Returns

boolean

Inherited from

AbstractStreamingSyncImplementation.isConnected

---

lastSyncedAt

Get Signature

get lastSyncedAt(): undefined | Date

Returns

undefined | Date

Inherited from

AbstractStreamingSyncImplementation.lastSyncedAt

---

webOptions

Get Signature

get webOptions(): WebStreamingSyncImplementationOptions

Returns

WebStreamingSyncImplementationOptions

Methods

connect()

connect(options?): Promise<void>

Connects to the sync service

Parameters

Parameter	Type
options?	PowerSyncConnectionOptions

Returns

Promise<void>

Inherited from

AbstractStreamingSyncImplementation.connect

---

disconnect()

disconnect(): Promise<void>

Disconnects from the sync services.

Returns

Promise<void>

Throws

if not connected or if abort is not controlled internally

Inherited from

AbstractStreamingSyncImplementation.disconnect

---

dispose()

dispose(): Promise<void>

Returns

Promise<void>

Inherited from

AbstractStreamingSyncImplementation.dispose

---

getWriteCheckpoint()

getWriteCheckpoint(): Promise<string>

Returns

Promise<string>

Inherited from

AbstractStreamingSyncImplementation.getWriteCheckpoint

---

iterateAsyncListeners()

iterateAsyncListeners(cb): Promise<void>

Parameters

Parameter	Type
cb	(listener) => Promise<any>

Returns

Promise<void>

Inherited from

AbstractStreamingSyncImplementation.iterateAsyncListeners

---

iterateListeners()

iterateListeners(cb): void

Parameters

Parameter	Type
cb	(listener) => any

Returns

void

Inherited from

AbstractStreamingSyncImplementation.iterateListeners

---

markConnectionMayHaveChanged()

markConnectionMayHaveChanged(): void

Returns

void

Inherited from

AbstractStreamingSyncImplementation.markConnectionMayHaveChanged

---

obtainLock()

obtainLock<T>(lockOptions): Promise<T>

Type Parameters

Type Parameter
T

Parameters

Parameter	Type
lockOptions	LockOptions<T>

Returns

Promise<T>

Overrides

AbstractStreamingSyncImplementation.obtainLock

---

registerListener()

registerListener(listener): () => void

Register a listener for updates to the PowerSync client.

Parameters

Parameter	Type
listener	Partial<StreamingSyncImplementationListener>

Returns

Function

Returns

void

Inherited from

AbstractStreamingSyncImplementation.registerListener

---

triggerCrudUpload()

triggerCrudUpload(): void

Returns

void

Inherited from

AbstractStreamingSyncImplementation.triggerCrudUpload

---

updateSubscriptions()

updateSubscriptions(subscriptions): void

Parameters

Parameter	Type
subscriptions	SubscribedStream[]

Returns

void

Inherited from

AbstractStreamingSyncImplementation.updateSubscriptions

---

waitForReady()

waitForReady(): Promise<void>

Returns

Promise<void>

Inherited from

AbstractStreamingSyncImplementation.waitForReady

---

waitForStatus()

waitForStatus(status): Promise<void>

Parameters

Parameter	Type
status	SyncStatusOptions

Returns

Promise<void>

Inherited from

AbstractStreamingSyncImplementation.waitForStatus

---

waitUntilStatusMatches()

waitUntilStatusMatches(predicate): Promise<void>

Parameters

Parameter	Type
predicate	(status) => boolean

Returns

Promise<void>

Inherited from

AbstractStreamingSyncImplementation.waitUntilStatusMatches