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.
- Defined in src/iterator/channel/source.ts:15