LeaderWorkerInnerPullStream

Defined in: packages/@livestore/adapter-web/src/web-worker/common/worker-schema.ts:95

Extends

• object & object & TaggedRequest<"PullStream", LeaderWorkerInnerPullStream, Encoded<object & object>, never, { payload: { newEvents: readonly EncodedWithMeta[]; rollbackEvents: readonly EncodedWithMeta[]; } | { newEvents: readonly EncodedWithMeta[]; }; }, { payload: { _tag: "upstream-rebase"; newEvents: readonly object[]; rollbackEvents: readonly object[]; } | { _tag: "upstream-advance"; newEvents: readonly object[]; }; }, UnexpectedError, { _tag: "LiveStore.UnexpectedError"; cause: unknown; note?: string; payload?: any; }, never, this>

Constructors

Constructor

new LeaderWorkerInnerPullStream(props, options?): LeaderWorkerInnerPullStream

Defined in: node_modules/.pnpm/effect@3.18.0/node_modules/effect/dist/dts/Schema.d.ts:4265

Parameters

props

cursor

{ client: number & Brand<"ClientEventSequenceNumber">; global: number & Brand<"GlobalEventSequenceNumber">; rebaseGeneration: number; } = EventSequenceNumber.EventSequenceNumber

cursor.client

number & Brand<"ClientEventSequenceNumber">

Only increments for client-local events

cursor.global

number & Brand<"GlobalEventSequenceNumber">

cursor.rebaseGeneration

number

options?

MakeOptions

Returns

LeaderWorkerInnerPullStream

Inherited from

Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).constructor

Properties

cursor

readonly cursor: object = EventSequenceNumber.EventSequenceNumber

Defined in: packages/@livestore/adapter-web/src/web-worker/common/worker-schema.ts:97

client

readonly client: number & Brand<"ClientEventSequenceNumber">

Only increments for client-local events

global

readonly global: number & Brand<"GlobalEventSequenceNumber">

rebaseGeneration

readonly rebaseGeneration: number

Inherited from

Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).cursor