@epikodelabs/streamix / src/public-api / AsyncIteratorState
Class: AsyncIteratorState<T>
Defined in: projects/libraries/streamix/src/lib/utils/helpers.ts:22
Core state management for async iterators with pull/push coordination
Type Parameters
T
T
Constructors
Constructor
new AsyncIteratorState<
T>():AsyncIteratorState<T>
Returns
AsyncIteratorState<T>
Properties
queue
readonlyqueue:QueueItem<T>[] =[]
Defined in: projects/libraries/streamix/src/lib/utils/helpers.ts:23
backpressureQueue
readonlybackpressureQueue: () =>void[] =[]
Defined in: projects/libraries/streamix/src/lib/utils/helpers.ts:24
Returns
void
pullResolve
pullResolve: (
v) =>void|null=null
Defined in: projects/libraries/streamix/src/lib/utils/helpers.ts:26
pullReject
pullReject: (
e) =>void|null=null
Defined in: projects/libraries/streamix/src/lib/utils/helpers.ts:27
pendingError
pendingError:
PendingError|null=null
Defined in: projects/libraries/streamix/src/lib/utils/helpers.ts:28
completed
completed:
boolean=false
Defined in: projects/libraries/streamix/src/lib/utils/helpers.ts:29
Methods
hasBufferedValues()
hasBufferedValues():
boolean
Defined in: projects/libraries/streamix/src/lib/utils/helpers.ts:34
Check if there are any buffered values, errors, or completion
Returns
boolean
clear()
clear():
void
Defined in: projects/libraries/streamix/src/lib/utils/helpers.ts:41
Clear all pending resolvers and backpressure
Returns
void
markCompleted()
markCompleted():
void
Defined in: projects/libraries/streamix/src/lib/utils/helpers.ts:56
Mark as completed and clear state
Returns
void
enqueueValue()
enqueueValue(
value):void
Defined in: projects/libraries/streamix/src/lib/utils/helpers.ts:64
Enqueue a value
Parameters
value
T
Returns
void
enqueueCompletion()
enqueueCompletion():
void
Defined in: projects/libraries/streamix/src/lib/utils/helpers.ts:73
Enqueue completion
Returns
void