@epikodelabs/streamix

---

@epikodelabs/streamix / AsyncIteratorState

Class: AsyncIteratorState<T>

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

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

---

backpressureQueue

readonly backpressureQueue: () => void[] = []

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

Returns

void

---

pullResolve

pullResolve: (v) => void | null = null

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

---

pullReject

pullReject: (e) => void | null = null

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

---

pendingError

pendingError: PendingError | null = null

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

---

completed

completed: boolean = false

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

Methods

hasBufferedValues()

hasBufferedValues(): boolean

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

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

Clear all pending resolvers and backpressure

Returns

void

---

markCompleted()

markCompleted(): void

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

Mark as completed and clear state

Returns

void

---

enqueueValue()

enqueueValue(value): void

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

Enqueue a value

Parameters

value

T

Returns

void

---

enqueueCompletion()

enqueueCompletion(): void

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

Enqueue completion

Returns

void