WritableIterable | /src/writable-iterable.ts | proc@0.20.22

Deno 2 is finally here 🎉️

A high-level way to run child processes that is easy, flexible, powerful, and prevents resource leaks.

class WritableIterable

implements Writable<T>, AsyncIterable<T>

import { WritableIterable } from "https://deno.land/x/proc@0.20.22/src/writable-iterable.ts";

Invert the normal data flow of an AsyncIterable, allowing you to push writes on one side and iterate on the other.

The write() side must call close() when all write operations are done.

Constructors

new

WritableIterable(options?: { onclose?: () => void | Promise<void>; })

Create a new PushIterable.

private

_closed: boolean

private

queue: QueueEntry<Some<T> | None>[]

readonly

isClosed

private

Add an unresolved promise to the end of the queue.

close(error?: Error): Promise<void>

write(item: T): Promise<void>

It is an AsyncIterable<T>.