Interface AsyncChannel

src/core/async-channel.ts:9–14

 */

export interface AsyncChannel<T> {
  push(value: T): void
  close(): void
  error(err: Error): void
  [Symbol.asyncIterator](): AsyncIterableIterator<T>
}

export function createChannel<T>(): AsyncChannel<T> {
  const queue: T[] = []