@epikodelabs/streamix

---

@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

readonly queue: QueueItem<T>[] = []

Defined in: projects/libraries/streamix/src/lib/utils/helpers.ts:23

---

backpressureQueue

readonly backpressureQueue: () => 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:66

Enqueue a value

Parameters

value

T

Returns

void

---

enqueueCompletion()

enqueueCompletion(): void

Defined in: projects/libraries/streamix/src/lib/utils/helpers.ts:75

Enqueue completion

Returns

void