LeaderWorkerInnerPullStream
Defined in: packages/@livestore/adapter-web/src/web-worker/common/worker-schema.ts:94
Extends
Section titled “Extends”object
&object
&TaggedRequest
<"PullStream"
,LeaderWorkerInnerPullStream
,Encoded
<object
&object
>,never
, {payload
: {_tag
:"upstream-rebase"
;newEvents
: readonlyEncodedWithMeta
[];rollbackEvents
: readonlyEncodedWithMeta
[]; } | {_tag
:"upstream-advance"
;newEvents
: readonlyEncodedWithMeta
[]; }; }, {payload
: {_tag
:"upstream-rebase"
;newEvents
: readonlyobject
[];rollbackEvents
: readonlyobject
[]; } | {_tag
:"upstream-advance"
;newEvents
: readonlyobject
[]; }; },UnexpectedError
, {_tag
:"LiveStore.UnexpectedError"
;cause
:unknown
;note?
:string
;payload?
:any
; },never
,this
>
Constructors
Section titled “Constructors”Constructor
Section titled “Constructor”new LeaderWorkerInnerPullStream(
props
,options?
):LeaderWorkerInnerPullStream
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Schema.d.ts:4265
Parameters
Section titled “Parameters”cursor
Section titled “cursor”{ client
: number
& Brand
<"ClientEventSequenceNumber"
>; global
: number
& Brand
<"GlobalEventSequenceNumber"
>; rebaseGeneration
: number
; } = EventSequenceNumber.EventSequenceNumber
cursor.client
Section titled “cursor.client”number
& Brand
<"ClientEventSequenceNumber"
>
Only increments for clientOnly events
cursor.global
Section titled “cursor.global”number
& Brand
<"GlobalEventSequenceNumber"
>
cursor.rebaseGeneration
Section titled “cursor.rebaseGeneration”number
options?
Section titled “options?”MakeOptions
Returns
Section titled “Returns”LeaderWorkerInnerPullStream
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).constructor
Properties
Section titled “Properties”
readonly
_tag:"PullStream"
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Schema.d.ts:5060
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, })._tag
[RequestTypeId]
Section titled “[RequestTypeId]”
readonly
[RequestTypeId]:object
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Request.d.ts:41
readonly
_A:Covariant
<{payload
: {_tag
:"upstream-rebase"
;newEvents
: readonlyEncodedWithMeta
[];rollbackEvents
: readonlyEncodedWithMeta
[]; } | {_tag
:"upstream-advance"
;newEvents
: readonlyEncodedWithMeta
[]; }; }>
readonly
_E:Covariant
<UnexpectedError
>
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).[RequestTypeId]
[symbolSerializable]
Section titled “[symbolSerializable]”
readonly
[symbolSerializable]:Schema
<LeaderWorkerInnerPullStream
,Encoded
<object
&object
>,never
>
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Schema.d.ts:4747
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).[symbolSerializable]
[symbolWithResult]
Section titled “[symbolWithResult]”
readonly
[symbolWithResult]:object
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Schema.d.ts:4820
failure
Section titled “failure”
readonly
failure:Schema
<UnexpectedError
, {_tag
:"LiveStore.UnexpectedError"
;cause
:unknown
;note?
:string
;payload?
:any
; },never
>
success
Section titled “success”
readonly
success:Schema
<{payload
: {_tag
:"upstream-rebase"
;newEvents
: readonlyEncodedWithMeta
[];rollbackEvents
: readonlyEncodedWithMeta
[]; } | {_tag
:"upstream-advance"
;newEvents
: readonlyEncodedWithMeta
[]; }; }, {payload
: {_tag
:"upstream-rebase"
;newEvents
: readonlyobject
[];rollbackEvents
: readonlyobject
[]; } | {_tag
:"upstream-advance"
;newEvents
: readonlyobject
[]; }; },never
>
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).[symbolWithResult]
cursor
Section titled “cursor”
readonly
cursor:object
=EventSequenceNumber.EventSequenceNumber
Defined in: packages/@livestore/adapter-web/src/web-worker/common/worker-schema.ts:96
client
Section titled “client”
readonly
client:number
&Brand
<"ClientEventSequenceNumber"
>
Only increments for clientOnly events
global
Section titled “global”
readonly
global:number
&Brand
<"GlobalEventSequenceNumber"
>
rebaseGeneration
Section titled “rebaseGeneration”
readonly
rebaseGeneration:number
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).cursor
readonly
static
_tag:"PullStream"
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Schema.d.ts:5034
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, })._tag
[TypeId]
Section titled “[TypeId]”
readonly
static
[TypeId]:object
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Schema.d.ts:160
readonly
_A:Invariant
<LeaderWorkerInnerPullStream
>
readonly
_I:Invariant
<{_tag
:"PullStream"
;cursor
: {client
:number
;global
:number
;rebaseGeneration
:number
; }; }>
readonly
_R:Covariant
<never
>
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).[TypeId]
readonly
static
ast:Transformation
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Schema.d.ts:4267
3.10.0
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).ast
Context
Section titled “Context”
readonly
static
Context:never
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Schema.d.ts:63
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).Context
Encoded
Section titled “Encoded”
readonly
static
Encoded:object
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Schema.d.ts:62
_tag:
"PullStream"
cursor
Section titled “cursor”cursor:
object
cursor.client
Section titled “cursor.client”client:
number
cursor.global
Section titled “cursor.global”global:
number
cursor.rebaseGeneration
Section titled “cursor.rebaseGeneration”rebaseGeneration:
number
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).Encoded
failure
Section titled “failure”
readonly
static
failure: typeofUnexpectedError
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Schema.d.ts:5036
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).failure
fields
Section titled “fields”
readonly
static
fields:object
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Schema.d.ts:4270
readonly
_tag:tag
<"PullStream"
>
cursor
Section titled “cursor”
readonly
cursor:Struct
<{client
:BrandSchema
<number
&Brand
<"ClientEventSequenceNumber"
>,number
,never
>;global
:BrandSchema
<number
&Brand
<"GlobalEventSequenceNumber"
>,number
,never
>;rebaseGeneration
: typeofInt
; }> =EventSequenceNumber.EventSequenceNumber
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).fields
identifier
Section titled “identifier”
readonly
static
identifier:string
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Schema.d.ts:4273
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).identifier
success
Section titled “success”
readonly
static
success:Struct
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Schema.d.ts:5035
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).success
readonly
static
Type:LeaderWorkerInnerPullStream
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Schema.d.ts:61
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).Type
Methods
Section titled “Methods”annotations()
Section titled “annotations()”
static
annotations(annotations
):SchemaClass
<LeaderWorkerInnerPullStream
, {_tag
:"PullStream"
;cursor
: {client
:number
;global
:number
;rebaseGeneration
:number
; }; },never
>
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Schema.d.ts:4269
Merges a set of new annotations with existing ones, potentially overwriting any duplicates.
Parameters
Section titled “Parameters”annotations
Section titled “annotations”Schema
<LeaderWorkerInnerPullStream
>
Returns
Section titled “Returns”SchemaClass
<LeaderWorkerInnerPullStream
, { _tag
: "PullStream"
; cursor
: { client
: number
; global
: number
; rebaseGeneration
: number
; }; }, never
>
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).annotations
extend()
Section titled “extend()”
static
extend<Extended
>(identifier
): <NewFields
>(fields
,annotations?
) => [Extended
] extends [never
] ?"Missing `Self` generic - use `class Self extends Base.extend<Self>()({ ... })`"
:Class
<Extended
,object
&object
&NewFields
,object
&object
& { readonly [K in string | number | symbol as Key<NewFields, K>]: Encoded<NewFields[K]> } & { readonly [K in string | number | symbol as Key<NewFields, K>]?: Encoded<NewFields[K]> },Context
<NewFields
[keyofNewFields
]>,object
&Constructor
<NewFields
>,LeaderWorkerInnerPullStream
, { }>
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Schema.d.ts:4296
Type Parameters
Section titled “Type Parameters”Extended
Section titled “Extended”Extended
= never
Parameters
Section titled “Parameters”identifier
Section titled “identifier”string
Returns
Section titled “Returns”<
NewFields
>(fields
,annotations?
): [Extended
] extends [never
] ?"Missing `Self` generic - use `class Self extends Base.extend<Self>()({ ... })`"
:Class
<Extended
,object
&object
&NewFields
,object
&object
& { readonly [K in string | number | symbol as Key<NewFields, K>]: Encoded<NewFields[K]> } & { readonly [K in string | number | symbol as Key<NewFields, K>]?: Encoded<NewFields[K]> },Context
<NewFields
[keyofNewFields
]>,object
&Constructor
<NewFields
>,LeaderWorkerInnerPullStream
, { }>
Type Parameters
Section titled “Type Parameters”NewFields
Section titled “NewFields”NewFields
extends Fields
Parameters
Section titled “Parameters”fields
Section titled “fields”NewFields
| HasFields
<NewFields
>
annotations?
Section titled “annotations?”ClassAnnotations
<Extended
, { [K in string | number | symbol]: Type<{ _tag: tag<“PullStream”> } & { cursor: Struct<{ client: BrandSchema<(…), (…), (…)>; global: BrandSchema<(…), (…), (…)>; rebaseGeneration: typeof Int }> } & NewFields>[K] }>
Returns
Section titled “Returns”[Extended
] extends [never
] ? "Missing `Self` generic - use `class Self extends Base.extend<Self>()({ ... })`"
: Class
<Extended
, object
& object
& NewFields
, object
& object
& { readonly [K in string | number | symbol as Key<NewFields, K>]: Encoded<NewFields[K]> } & { readonly [K in string | number | symbol as Key<NewFields, K>]?: Encoded<NewFields[K]> }, Context
<NewFields
[keyof NewFields
]>, object
& Constructor
<NewFields
>, LeaderWorkerInnerPullStream
, { }>
Example
Section titled “Example”import { Schema } from "effect"
class MyClass extends Schema.Class<MyClass>("MyClass")({ myField: Schema.String}) { myMethod() { return this.myField + "my" }}
class NextClass extends MyClass.extend<NextClass>("NextClass")({ nextField: Schema.Number}) { nextMethod() { return this.myMethod() + this.myField + this.nextField }}
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).extend
make()
Section titled “make()”
static
make<C
>(this
, …args
):InstanceType
<C
>
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Schema.d.ts:4268
Type Parameters
Section titled “Type Parameters”C
extends (…args
) => any
Parameters
Section titled “Parameters”C
…ConstructorParameters
<C
>
Returns
Section titled “Returns”InstanceType
<C
>
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).make
pipe()
Section titled “pipe()”Call Signature
Section titled “Call Signature”
static
pipe<A
>(this
):A
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:10
Type Parameters
Section titled “Type Parameters”A
Parameters
Section titled “Parameters”A
Returns
Section titled “Returns”A
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).pipe
Call Signature
Section titled “Call Signature”
static
pipe<A
,B
>(this
,ab
):B
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:11
Type Parameters
Section titled “Type Parameters”A
B
= never
Parameters
Section titled “Parameters”A
(_
) => B
Returns
Section titled “Returns”B
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).pipe
Call Signature
Section titled “Call Signature”
static
pipe<A
,B
,C
>(this
,ab
,bc
):C
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:12
Type Parameters
Section titled “Type Parameters”A
B
= never
C
= never
Parameters
Section titled “Parameters”A
(_
) => B
(_
) => C
Returns
Section titled “Returns”C
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).pipe
Call Signature
Section titled “Call Signature”
static
pipe<A
,B
,C
,D
>(this
,ab
,bc
,cd
):D
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:13
Type Parameters
Section titled “Type Parameters”A
B
= never
C
= never
D
= never
Parameters
Section titled “Parameters”A
(_
) => B
(_
) => C
(_
) => D
Returns
Section titled “Returns”D
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).pipe
Call Signature
Section titled “Call Signature”
static
pipe<A
,B
,C
,D
,E
>(this
,ab
,bc
,cd
,de
):E
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:14
Type Parameters
Section titled “Type Parameters”A
B
= never
C
= never
D
= never
E
= never
Parameters
Section titled “Parameters”A
(_
) => B
(_
) => C
(_
) => D
(_
) => E
Returns
Section titled “Returns”E
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).pipe
Call Signature
Section titled “Call Signature”
static
pipe<A
,B
,C
,D
,E
,F
>(this
,ab
,bc
,cd
,de
,ef
):F
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:15
Type Parameters
Section titled “Type Parameters”A
B
= never
C
= never
D
= never
E
= never
F
= never
Parameters
Section titled “Parameters”A
(_
) => B
(_
) => C
(_
) => D
(_
) => E
(_
) => F
Returns
Section titled “Returns”F
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).pipe
Call Signature
Section titled “Call Signature”
static
pipe<A
,B
,C
,D
,E
,F
,G
>(this
,ab
,bc
,cd
,de
,ef
,fg
):G
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:16
Type Parameters
Section titled “Type Parameters”A
B
= never
C
= never
D
= never
E
= never
F
= never
G
= never
Parameters
Section titled “Parameters”A
(_
) => B
(_
) => C
(_
) => D
(_
) => E
(_
) => F
(_
) => G
Returns
Section titled “Returns”G
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).pipe
Call Signature
Section titled “Call Signature”
static
pipe<A
,B
,C
,D
,E
,F
,G
,H
>(this
,ab
,bc
,cd
,de
,ef
,fg
,gh
):H
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:17
Type Parameters
Section titled “Type Parameters”A
B
= never
C
= never
D
= never
E
= never
F
= never
G
= never
H
= never
Parameters
Section titled “Parameters”A
(_
) => B
(_
) => C
(_
) => D
(_
) => E
(_
) => F
(_
) => G
(_
) => H
Returns
Section titled “Returns”H
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).pipe
Call Signature
Section titled “Call Signature”
static
pipe<A
,B
,C
,D
,E
,F
,G
,H
,I
>(this
,ab
,bc
,cd
,de
,ef
,fg
,gh
,hi
):I
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:18
Type Parameters
Section titled “Type Parameters”A
B
= never
C
= never
D
= never
E
= never
F
= never
G
= never
H
= never
I
= never
Parameters
Section titled “Parameters”A
(_
) => B
(_
) => C
(_
) => D
(_
) => E
(_
) => F
(_
) => G
(_
) => H
(_
) => I
Returns
Section titled “Returns”I
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).pipe
Call Signature
Section titled “Call Signature”
static
pipe<A
,B
,C
,D
,E
,F
,G
,H
,I
,J
>(this
,ab
,bc
,cd
,de
,ef
,fg
,gh
,hi
,ij
):J
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:19
Type Parameters
Section titled “Type Parameters”A
B
= never
C
= never
D
= never
E
= never
F
= never
G
= never
H
= never
I
= never
J
= never
Parameters
Section titled “Parameters”A
(_
) => B
(_
) => C
(_
) => D
(_
) => E
(_
) => F
(_
) => G
(_
) => H
(_
) => I
(_
) => J
Returns
Section titled “Returns”J
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).pipe
Call Signature
Section titled “Call Signature”
static
pipe<A
,B
,C
,D
,E
,F
,G
,H
,I
,J
,K
>(this
,ab
,bc
,cd
,de
,ef
,fg
,gh
,hi
,ij
,jk
):K
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:20
Type Parameters
Section titled “Type Parameters”A
B
= never
C
= never
D
= never
E
= never
F
= never
G
= never
H
= never
I
= never
J
= never
K
= never
Parameters
Section titled “Parameters”A
(_
) => B
(_
) => C
(_
) => D
(_
) => E
(_
) => F
(_
) => G
(_
) => H
(_
) => I
(_
) => J
(_
) => K
Returns
Section titled “Returns”K
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).pipe
Call Signature
Section titled “Call Signature”
static
pipe<A
,B
,C
,D
,E
,F
,G
,H
,I
,J
,K
,L
>(this
,ab
,bc
,cd
,de
,ef
,fg
,gh
,hi
,ij
,jk
,kl
):L
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:21
Type Parameters
Section titled “Type Parameters”A
B
= never
C
= never
D
= never
E
= never
F
= never
G
= never
H
= never
I
= never
J
= never
K
= never
L
= never
Parameters
Section titled “Parameters”A
(_
) => B
(_
) => C
(_
) => D
(_
) => E
(_
) => F
(_
) => G
(_
) => H
(_
) => I
(_
) => J
(_
) => K
(_
) => L
Returns
Section titled “Returns”L
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).pipe
Call Signature
Section titled “Call Signature”
static
pipe<A
,B
,C
,D
,E
,F
,G
,H
,I
,J
,K
,L
,M
>(this
,ab
,bc
,cd
,de
,ef
,fg
,gh
,hi
,ij
,jk
,kl
,lm
):M
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:22
Type Parameters
Section titled “Type Parameters”A
B
= never
C
= never
D
= never
E
= never
F
= never
G
= never
H
= never
I
= never
J
= never
K
= never
L
= never
M
= never
Parameters
Section titled “Parameters”A
(_
) => B
(_
) => C
(_
) => D
(_
) => E
(_
) => F
(_
) => G
(_
) => H
(_
) => I
(_
) => J
(_
) => K
(_
) => L
(_
) => M
Returns
Section titled “Returns”M
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).pipe
Call Signature
Section titled “Call Signature”
static
pipe<A
,B
,C
,D
,E
,F
,G
,H
,I
,J
,K
,L
,M
,N
>(this
,ab
,bc
,cd
,de
,ef
,fg
,gh
,hi
,ij
,jk
,kl
,lm
,mn
):N
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:23
Type Parameters
Section titled “Type Parameters”A
B
= never
C
= never
D
= never
E
= never
F
= never
G
= never
H
= never
I
= never
J
= never
K
= never
L
= never
M
= never
N
= never
Parameters
Section titled “Parameters”A
(_
) => B
(_
) => C
(_
) => D
(_
) => E
(_
) => F
(_
) => G
(_
) => H
(_
) => I
(_
) => J
(_
) => K
(_
) => L
(_
) => M
(_
) => N
Returns
Section titled “Returns”N
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).pipe
Call Signature
Section titled “Call Signature”
static
pipe<A
,B
,C
,D
,E
,F
,G
,H
,I
,J
,K
,L
,M
,N
,O
>(this
,ab
,bc
,cd
,de
,ef
,fg
,gh
,hi
,ij
,jk
,kl
,lm
,mn
,no
):O
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:24
Type Parameters
Section titled “Type Parameters”A
B
= never
C
= never
D
= never
E
= never
F
= never
G
= never
H
= never
I
= never
J
= never
K
= never
L
= never
M
= never
N
= never
O
= never
Parameters
Section titled “Parameters”A
(_
) => B
(_
) => C
(_
) => D
(_
) => E
(_
) => F
(_
) => G
(_
) => H
(_
) => I
(_
) => J
(_
) => K
(_
) => L
(_
) => M
(_
) => N
(_
) => O
Returns
Section titled “Returns”O
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).pipe
Call Signature
Section titled “Call Signature”
static
pipe<A
,B
,C
,D
,E
,F
,G
,H
,I
,J
,K
,L
,M
,N
,O
,P
>(this
,ab
,bc
,cd
,de
,ef
,fg
,gh
,hi
,ij
,jk
,kl
,lm
,mn
,no
,op
):P
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:25
Type Parameters
Section titled “Type Parameters”A
B
= never
C
= never
D
= never
E
= never
F
= never
G
= never
H
= never
I
= never
J
= never
K
= never
L
= never
M
= never
N
= never
O
= never
P
= never
Parameters
Section titled “Parameters”A
(_
) => B
(_
) => C
(_
) => D
(_
) => E
(_
) => F
(_
) => G
(_
) => H
(_
) => I
(_
) => J
(_
) => K
(_
) => L
(_
) => M
(_
) => N
(_
) => O
(_
) => P
Returns
Section titled “Returns”P
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).pipe
Call Signature
Section titled “Call Signature”
static
pipe<A
,B
,C
,D
,E
,F
,G
,H
,I
,J
,K
,L
,M
,N
,O
,P
,Q
>(this
,ab
,bc
,cd
,de
,ef
,fg
,gh
,hi
,ij
,jk
,kl
,lm
,mn
,no
,op
,pq
):Q
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:26
Type Parameters
Section titled “Type Parameters”A
B
= never
C
= never
D
= never
E
= never
F
= never
G
= never
H
= never
I
= never
J
= never
K
= never
L
= never
M
= never
N
= never
O
= never
P
= never
Q
= never
Parameters
Section titled “Parameters”A
(_
) => B
(_
) => C
(_
) => D
(_
) => E
(_
) => F
(_
) => G
(_
) => H
(_
) => I
(_
) => J
(_
) => K
(_
) => L
(_
) => M
(_
) => N
(_
) => O
(_
) => P
(_
) => Q
Returns
Section titled “Returns”Q
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).pipe
Call Signature
Section titled “Call Signature”
static
pipe<A
,B
,C
,D
,E
,F
,G
,H
,I
,J
,K
,L
,M
,N
,O
,P
,Q
,R
>(this
,ab
,bc
,cd
,de
,ef
,fg
,gh
,hi
,ij
,jk
,kl
,lm
,mn
,no
,op
,pq
,qr
):R
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:27
Type Parameters
Section titled “Type Parameters”A
B
= never
C
= never
D
= never
E
= never
F
= never
G
= never
H
= never
I
= never
J
= never
K
= never
L
= never
M
= never
N
= never
O
= never
P
= never
Q
= never
R
= never
Parameters
Section titled “Parameters”A
(_
) => B
(_
) => C
(_
) => D
(_
) => E
(_
) => F
(_
) => G
(_
) => H
(_
) => I
(_
) => J
(_
) => K
(_
) => L
(_
) => M
(_
) => N
(_
) => O
(_
) => P
(_
) => Q
(_
) => R
Returns
Section titled “Returns”R
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).pipe
Call Signature
Section titled “Call Signature”
static
pipe<A
,B
,C
,D
,E
,F
,G
,H
,I
,J
,K
,L
,M
,N
,O
,P
,Q
,R
,S
>(this
,ab
,bc
,cd
,de
,ef
,fg
,gh
,hi
,ij
,jk
,kl
,lm
,mn
,no
,op
,pq
,qr
,rs
):S
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:28
Type Parameters
Section titled “Type Parameters”A
B
= never
C
= never
D
= never
E
= never
F
= never
G
= never
H
= never
I
= never
J
= never
K
= never
L
= never
M
= never
N
= never
O
= never
P
= never
Q
= never
R
= never
S
= never
Parameters
Section titled “Parameters”A
(_
) => B
(_
) => C
(_
) => D
(_
) => E
(_
) => F
(_
) => G
(_
) => H
(_
) => I
(_
) => J
(_
) => K
(_
) => L
(_
) => M
(_
) => N
(_
) => O
(_
) => P
(_
) => Q
(_
) => R
(_
) => S
Returns
Section titled “Returns”S
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).pipe
Call Signature
Section titled “Call Signature”
static
pipe<A
,B
,C
,D
,E
,F
,G
,H
,I
,J
,K
,L
,M
,N
,O
,P
,Q
,R
,S
,T
>(this
,ab
,bc
,cd
,de
,ef
,fg
,gh
,hi
,ij
,jk
,kl
,lm
,mn
,no
,op
,pq
,qr
,rs
,st
):T
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:29
Type Parameters
Section titled “Type Parameters”A
B
= never
C
= never
D
= never
E
= never
F
= never
G
= never
H
= never
I
= never
J
= never
K
= never
L
= never
M
= never
N
= never
O
= never
P
= never
Q
= never
R
= never
S
= never
T
= never
Parameters
Section titled “Parameters”A
(_
) => B
(_
) => C
(_
) => D
(_
) => E
(_
) => F
(_
) => G
(_
) => H
(_
) => I
(_
) => J
(_
) => K
(_
) => L
(_
) => M
(_
) => N
(_
) => O
(_
) => P
(_
) => Q
(_
) => R
(_
) => S
(_
) => T
Returns
Section titled “Returns”T
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).pipe
Call Signature
Section titled “Call Signature”
static
pipe<A
,B
,C
,D
,E
,F
,G
,H
,I
,J
,K
,L
,M
,N
,O
,P
,Q
,R
,S
,T
,U
>(this
,ab
,bc
,cd
,de
,ef
,fg
,gh
,hi
,ij
,jk
,kl
,lm
,mn
,no
,op
,pq
,qr
,rs
,st
,tu
):U
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:30
Type Parameters
Section titled “Type Parameters”A
B
= never
C
= never
D
= never
E
= never
F
= never
G
= never
H
= never
I
= never
J
= never
K
= never
L
= never
M
= never
N
= never
O
= never
P
= never
Q
= never
R
= never
S
= never
T
= never
U
= never
Parameters
Section titled “Parameters”A
(_
) => B
(_
) => C
(_
) => D
(_
) => E
(_
) => F
(_
) => G
(_
) => H
(_
) => I
(_
) => J
(_
) => K
(_
) => L
(_
) => M
(_
) => N
(_
) => O
(_
) => P
(_
) => Q
(_
) => R
(_
) => S
(_
) => T
(_
) => U
Returns
Section titled “Returns”U
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).pipe
Call Signature
Section titled “Call Signature”
static
pipe<A
,B
,C
,D
,E
,F
,G
,H
,I
,J
,K
,L
,M
,N
,O
,P
,Q
,R
,S
,T
,U
>(this
,ab
,bc
,cd
,de
,ef
,fg
,gh
,hi
,ij
,jk
,kl
,lm
,mn
,no
,op
,pq
,qr
,rs
,st
,tu
):U
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:31
Type Parameters
Section titled “Type Parameters”A
B
= never
C
= never
D
= never
E
= never
F
= never
G
= never
H
= never
I
= never
J
= never
K
= never
L
= never
M
= never
N
= never
O
= never
P
= never
Q
= never
R
= never
S
= never
T
= never
U
= never
Parameters
Section titled “Parameters”A
(_
) => B
(_
) => C
(_
) => D
(_
) => E
(_
) => F
(_
) => G
(_
) => H
(_
) => I
(_
) => J
(_
) => K
(_
) => L
(_
) => M
(_
) => N
(_
) => O
(_
) => P
(_
) => Q
(_
) => R
(_
) => S
(_
) => T
(_
) => U
Returns
Section titled “Returns”U
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).pipe
transformOrFail()
Section titled “transformOrFail()”
static
transformOrFail<Transformed
>(identifier
): <NewFields
,R2
,R3
>(fields
,options
,annotations?
) => [Transformed
] extends [never
] ?"Missing `Self` generic - use `class Self extends Base.transformOrFail<Self>()({ ... })`"
:Class
<Transformed
,object
&object
&NewFields
,Encoded
<object
&object
>,R2
|R3
|Context
<NewFields
[keyofNewFields
]>,object
&Constructor
<NewFields
>,LeaderWorkerInnerPullStream
, { }>
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Schema.d.ts:4326
Type Parameters
Section titled “Type Parameters”Transformed
Section titled “Transformed”Transformed
= never
Parameters
Section titled “Parameters”identifier
Section titled “identifier”string
Returns
Section titled “Returns”<
NewFields
,R2
,R3
>(fields
,options
,annotations?
): [Transformed
] extends [never
] ?"Missing `Self` generic - use `class Self extends Base.transformOrFail<Self>()({ ... })`"
:Class
<Transformed
,object
&object
&NewFields
,Encoded
<object
&object
>,R2
|R3
|Context
<NewFields
[keyofNewFields
]>,object
&Constructor
<NewFields
>,LeaderWorkerInnerPullStream
, { }>
Type Parameters
Section titled “Type Parameters”NewFields
Section titled “NewFields”NewFields
extends Fields
R2
R3
Parameters
Section titled “Parameters”fields
Section titled “fields”NewFields
options
Section titled “options”decode
Section titled “decode”(input
, options
, ast
) => Effect
<{ [K in string | number | symbol]: Type<{ _tag: tag<“PullStream”> } & { cursor: Struct<{ client: …; global: …; rebaseGeneration: … }> } & NewFields>[K] }, ParseIssue
, R2
>
encode
Section titled “encode”(input
, options
, ast
) => Effect
<object
& object
, ParseIssue
, R3
>
annotations?
Section titled “annotations?”ClassAnnotations
<Transformed
, { [K in string | number | symbol]: Type<{ _tag: tag<“PullStream”> } & { cursor: Struct<{ client: BrandSchema<(…), (…), (…)>; global: BrandSchema<(…), (…), (…)>; rebaseGeneration: typeof Int }> } & NewFields>[K] }>
Returns
Section titled “Returns”[Transformed
] extends [never
] ? "Missing `Self` generic - use `class Self extends Base.transformOrFail<Self>()({ ... })`"
: Class
<Transformed
, object
& object
& NewFields
, Encoded
<object
& object
>, R2
| R3
| Context
<NewFields
[keyof NewFields
]>, object
& Constructor
<NewFields
>, LeaderWorkerInnerPullStream
, { }>
Example
Section titled “Example”import { Effect, Schema } from "effect"
class MyClass extends Schema.Class<MyClass>("MyClass")({ myField: Schema.String}) { myMethod() { return this.myField + "my" }}
class NextClass extends MyClass.transformOrFail<NextClass>("NextClass")({ nextField: Schema.Number}, { decode: (i) => Effect.succeed({ myField: i.myField, nextField: i.myField.length }), encode: (a) => Effect.succeed({ myField: a.myField })}) { nextMethod() { return this.myMethod() + this.myField + this.nextField }}
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).transformOrFail
transformOrFailFrom()
Section titled “transformOrFailFrom()”
static
transformOrFailFrom<Transformed
>(identifier
): <NewFields
,R2
,R3
>(fields
,options
,annotations?
) => [Transformed
] extends [never
] ?"Missing `Self` generic - use `class Self extends Base.transformOrFailFrom<Self>()({ ... })`"
:Class
<Transformed
,object
&object
&NewFields
,Encoded
<object
&object
>,R2
|R3
|Context
<NewFields
[keyofNewFields
]>,object
&Constructor
<NewFields
>,LeaderWorkerInnerPullStream
, { }>
Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Schema.d.ts:4359
Type Parameters
Section titled “Type Parameters”Transformed
Section titled “Transformed”Transformed
= never
Parameters
Section titled “Parameters”identifier
Section titled “identifier”string
Returns
Section titled “Returns”<
NewFields
,R2
,R3
>(fields
,options
,annotations?
): [Transformed
] extends [never
] ?"Missing `Self` generic - use `class Self extends Base.transformOrFailFrom<Self>()({ ... })`"
:Class
<Transformed
,object
&object
&NewFields
,Encoded
<object
&object
>,R2
|R3
|Context
<NewFields
[keyofNewFields
]>,object
&Constructor
<NewFields
>,LeaderWorkerInnerPullStream
, { }>
Type Parameters
Section titled “Type Parameters”NewFields
Section titled “NewFields”NewFields
extends Fields
R2
R3
Parameters
Section titled “Parameters”fields
Section titled “fields”NewFields
options
Section titled “options”decode
Section titled “decode”(input
, options
, ast
) => Effect
<{ [K in string | number | symbol]: ({ _tag: “PullStream”; cursor: { client: number; global: number; rebaseGeneration: number } } & {} & { readonly [K in string | number | symbol as Key<NewFields, K>]: Encoded<NewFields[K]> } & { readonly [K in string | number | symbol as Key<NewFields, K>]?: Encoded<(…)[(…)]> })[K] }, ParseIssue
, R2
>
encode
Section titled “encode”(input
, options
, ast
) => Effect
<Encoded
<object
& object
>, ParseIssue
, R3
>
annotations?
Section titled “annotations?”ClassAnnotations
<Transformed
, { [K in string | number | symbol]: Type<{ _tag: tag<“PullStream”> } & { cursor: Struct<{ client: BrandSchema<(…), (…), (…)>; global: BrandSchema<(…), (…), (…)>; rebaseGeneration: typeof Int }> } & NewFields>[K] }>
Returns
Section titled “Returns”[Transformed
] extends [never
] ? "Missing `Self` generic - use `class Self extends Base.transformOrFailFrom<Self>()({ ... })`"
: Class
<Transformed
, object
& object
& NewFields
, Encoded
<object
& object
>, R2
| R3
| Context
<NewFields
[keyof NewFields
]>, object
& Constructor
<NewFields
>, LeaderWorkerInnerPullStream
, { }>
Example
Section titled “Example”import { Effect, Schema } from "effect"
class MyClass extends Schema.Class<MyClass>("MyClass")({ myField: Schema.String}) { myMethod() { return this.myField + "my" }}
class NextClass extends MyClass.transformOrFailFrom<NextClass>("NextClass")({ nextField: Schema.Number}, { decode: (i) => Effect.succeed({ myField: i.myField, nextField: i.myField.length }), encode: (a) => Effect.succeed({ myField: a.myField })}) { nextMethod() { return this.myMethod() + this.myField + this.nextField }}
Inherited from
Section titled “Inherited from”Schema.TaggedRequest<LeaderWorkerInnerPullStream>()('PullStream', { payload: { cursor: EventSequenceNumber.EventSequenceNumber, }, success: Schema.Struct({ payload: SyncState.PayloadUpstream, }), failure: UnexpectedError, }).transformOrFailFrom