import { ReadableStreamDefaultController } from "https://deno.land/x/deno@v0.30.0/cli/js/streams/readable-stream-default-controller.ts";
Properties
[q.queue_]: Queue<q.QueueElement<OutputType>>
[rs.controlledReadableStream_]: rs.SDReadableStream<OutputType>
[rs.pullAlgorithm_]: rs.PullAlgorithm<OutputType>
[rs.strategySizeAlgorithm_]: QueuingStrategySizeCallback<OutputType>
Methods
close(): void
enqueue(chunk?: OutputType): void
error(e?: shared.ErrorResult): void
[rs.cancelSteps_](reason: shared.ErrorResult): Promise<void>
[rs.pullSteps_](forAuthorCode: boolean): Promise<IteratorResult<OutputType, any>>