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: any; global: any; rebaseGeneration: number; }; seqNum: { client: any; global: any; 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: "LiveStore.UnknownError"; cause: unknown; note?: string; payload?: any; }, never, this>

Constructors

Constructor

new LeaderWorkerInnerStreamEvents(props, options?): LeaderWorkerInnerStreamEvents

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

Parameters

props

void | { batchSize?: number; clientIds?: readonly string[]; filter?: readonly string[]; includeClientOnly?: boolean; sessionIds?: readonly string[]; since?: { client: any; global: any; rebaseGeneration: number; }; until?: { client: any; global: any; 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:121

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:119

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:118

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:122

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:120

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:104

client

readonly client: any

global

readonly global: any

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:111

client

readonly client: any

global

readonly global: any

rebaseGeneration

readonly rebaseGeneration: number

Inherited from

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