Function createAsyncSource

createAsyncSource<Y, R, E>(
    events: AsyncEvent<Y, R, E>[],
    waiters: (() => void)[],
    result_promise: Promise<R>,
): AsyncSource<Y, R, E>
Creates an AsyncSource backed by a shared event buffer.
Type Parameters
- Y
  Yielded value type.
- R
  Return value type.
- E
  Error type.
Parameters
- events: AsyncEvent<Y, R, E>[]
  The shared event buffer to read from.
- waiters: (() => void)[]
  The shared waiter list; resolved when new events arrive.
- result_promise: Promise<R>
  A promise that resolves/rejects with the channel result.
Returns AsyncSource<Y, R, E>
An AsyncSource.

Remarks
Subscribers replay buffered events synchronously and stop at the first terminal event. A callback exception propagates to the caller flushing the subscription and detaches that subscriber. The producer must notify the remaining waiters even if one throws, as createAsyncChannel does.
- Defined in iterator/channel/source.ts:21