LeaderWorkerInnerPullStream

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

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[]; }; }, UnknownError, { _tag: "UnknownError"; cause: unknown; note?: string; payload?: any; }, never, this>

Constructors

Constructor

new LeaderWorkerInnerPullStream(props, options?): LeaderWorkerInnerPullStream

Defined in: .pnpm-home/store/v11/links/@/effect/3.21.0/5f824b960b722ac9cc27ad83fe3b2945d775b034a0e1eb327a0ff67a4a7c6da7/node_modules/effect/dist/dts/Schema.d.ts:4266

Parameters

props

cursor

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

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: Schema.typeSchema(EventSequenceNumber.Client.Composite), }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnknownError, }).constructor

Properties

cursor

readonly cursor: object

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

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: Schema.typeSchema(EventSequenceNumber.Client.Composite), }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnknownError, }).cursor