LeaderWorkerInnerStreamEvents

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

Extends

• object & object & object & object & object & object & object & object & TaggedRequest<"StreamEvents", LeaderWorkerInnerStreamEvents, Encoded<object & object>, never, { args: any; clientId: string; name: string; parentSeqNum: { client: number & Brand<"ClientEventSequenceNumber">; global: number & Brand<"GlobalEventSequenceNumber">; rebaseGeneration: number; }; seqNum: { client: number & Brand<"ClientEventSequenceNumber">; global: number & Brand<"GlobalEventSequenceNumber">; rebaseGeneration: number; }; sessionId: string; }, { args: any; clientId: string; name: string; parentSeqNum: { client: number; global: number; rebaseGeneration: number; }; seqNum: { client: number; global: number; rebaseGeneration: number; }; sessionId: string; }, UnknownError, { _tag: "UnknownError"; cause: unknown; note?: string; payload?: any; }, never, this>

Constructors

Constructor

new LeaderWorkerInnerStreamEvents(props, options?): LeaderWorkerInnerStreamEvents

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

Parameters

props

void | { batchSize?: number; clientIds?: readonly string[]; filter?: readonly string[]; includeClientOnly?: boolean; sessionIds?: readonly string[]; since?: { client: number & Brand<"ClientEventSequenceNumber">; global: number & Brand<"GlobalEventSequenceNumber">; rebaseGeneration: number; }; until?: { client: number & Brand<"ClientEventSequenceNumber">; global: number & Brand<"GlobalEventSequenceNumber">; rebaseGeneration: number; }; }

options?

MakeOptions

Returns

LeaderWorkerInnerStreamEvents

Inherited from

Schema.TaggedRequest<LeaderWorkerInnerStreamEvents>()( 'StreamEvents', { payload: StreamEventsOptionsFields, success: LiveStoreEvent.Client.Encoded, failure: UnknownError, }, ).constructor

Properties

batchSize?

readonly optional batchSize: number

Defined in: packages/@livestore/common/dist/leader-thread/types.d.ts:122

Inherited from

Schema.TaggedRequest<LeaderWorkerInnerStreamEvents>()( 'StreamEvents', { payload: StreamEventsOptionsFields, success: LiveStoreEvent.Client.Encoded, failure: UnknownError, }, ).batchSize

---

clientIds?

readonly optional clientIds: readonly string[]

Defined in: packages/@livestore/common/dist/leader-thread/types.d.ts:120

Inherited from

Schema.TaggedRequest<LeaderWorkerInnerStreamEvents>()( 'StreamEvents', { payload: StreamEventsOptionsFields, success: LiveStoreEvent.Client.Encoded, failure: UnknownError, }, ).clientIds

---

filter?

readonly optional filter: readonly string[]

Defined in: packages/@livestore/common/dist/leader-thread/types.d.ts:119

Inherited from

Schema.TaggedRequest<LeaderWorkerInnerStreamEvents>()( 'StreamEvents', { payload: StreamEventsOptionsFields, success: LiveStoreEvent.Client.Encoded, failure: UnknownError, }, ).filter

---

includeClientOnly?

readonly optional includeClientOnly: boolean

Defined in: packages/@livestore/common/dist/leader-thread/types.d.ts:123

Inherited from

Schema.TaggedRequest<LeaderWorkerInnerStreamEvents>()( 'StreamEvents', { payload: StreamEventsOptionsFields, success: LiveStoreEvent.Client.Encoded, failure: UnknownError, }, ).includeClientOnly

---

sessionIds?

readonly optional sessionIds: readonly string[]

Defined in: packages/@livestore/common/dist/leader-thread/types.d.ts:121

Inherited from

Schema.TaggedRequest<LeaderWorkerInnerStreamEvents>()( 'StreamEvents', { payload: StreamEventsOptionsFields, success: LiveStoreEvent.Client.Encoded, failure: UnknownError, }, ).sessionIds

---

since?

readonly optional since: object

Defined in: packages/@livestore/common/dist/leader-thread/types.d.ts:105

client

readonly client: number & Brand<"ClientEventSequenceNumber">

global

readonly global: number & Brand<"GlobalEventSequenceNumber">

rebaseGeneration

readonly rebaseGeneration: number

Inherited from

Schema.TaggedRequest<LeaderWorkerInnerStreamEvents>()( 'StreamEvents', { payload: StreamEventsOptionsFields, success: LiveStoreEvent.Client.Encoded, failure: UnknownError, }, ).since

---

until?

readonly optional until: object

Defined in: packages/@livestore/common/dist/leader-thread/types.d.ts:112

client

readonly client: number & Brand<"ClientEventSequenceNumber">

global

readonly global: number & Brand<"GlobalEventSequenceNumber">

rebaseGeneration

readonly rebaseGeneration: number

Inherited from

Schema.TaggedRequest<LeaderWorkerInnerStreamEvents>()( 'StreamEvents', { payload: StreamEventsOptionsFields, success: LiveStoreEvent.Client.Encoded, failure: UnknownError, }, ).until