ReadableStreamDefaultControllerImpl | /cli/js/web/streams/readable_stream_default_controller.ts | deno@v1.0.0

Module

x/deno/cli/js/web/streams/readable_stream_default_controller.ts>ReadableStreamDefaultControllerImpl

A modern runtime for JavaScript and TypeScript.

denoland/deno

Go to Latest

readable_stream_default_reader.ts

ReadableStreamDefaultReaderImpl

queuing_strategy.ts

ByteLengthQueuingStrategyImpl

CountQueuingStrategyImpl

transform_stream.ts

TransformStreamImpl

transform_stream_default_controller.ts

TransformStreamDefaultControllerImpl

autoAllocateChunkSize

backpressure

backpressureChangePromise

controlledReadableByteStream

controlledReadableStream

controlledTransformStream

controlledWritableStream

readableStreamController

strategySizeAlgorithm

transformAlgorithm

transformStreamController

writable

writableStreamController

writable_stream_default_controller.ts

WritableStreamDefaultControllerImpl

writable_stream_default_writer.ts

WritableStreamDefaultWriterImpl

readable_stream.ts

ReadableStreamImpl

readable_stream_default_controller.ts

ReadableStreamDefaultControllerImpl

readable_byte_stream_controller.ts

ReadableByteStreamControllerImpl

readable_stream_async_iterator.ts

ReadableStreamAsyncIteratorPrototype

ReadableStreamAsyncIterator

ReadableStreamGenericReader

acquireReadableStreamDefaultReader

acquireWritableStreamDefaultWriter

call

dequeueValue

getDeferred

initializeReadableStream

initializeTransformStream

initializeWritableStream

invokeOrNoop

isDetachedBuffer

isReadableByteStreamController

isReadableStream

isReadableStreamAsyncIterator

isReadableStreamDefaultController

isReadableStreamDefaultReader

isReadableStreamLocked

isTransformStream

isTransformStreamDefaultController

isUnderlyingByteSource

isWritableStream

isWritableStreamDefaultController

isWritableStreamDefaultWriter

isWritableStreamLocked

makeSizeAlgorithmFromSizeFunction

readableByteStreamControllerCallPullIfNeeded

readableByteStreamControllerClearAlgorithms

readableByteStreamControllerClose

readableByteStreamControllerEnqueue

readableByteStreamControllerError

readableByteStreamControllerGetDesiredSize

readableByteStreamControllerHandleQueueDrain

readableStreamAddReadRequest

readableStreamCancel

readableStreamClose

readableStreamCreateReadResult

readableStreamDefaultControllerCallPullIfNeeded

readableStreamDefaultControllerCanCloseOrEnqueue

readableStreamDefaultControllerClearAlgorithms

readableStreamDefaultControllerClose

readableStreamDefaultControllerEnqueue

readableStreamDefaultControllerError

readableStreamDefaultControllerGetDesiredSize

readableStreamDefaultReaderRead

readableStreamError

readableStreamFulfillReadRequest

readableStreamGetNumReadRequests

readableStreamHasDefaultReader

readableStreamPipeTo

readableStreamReaderGenericCancel

readableStreamReaderGenericInitialize

readableStreamReaderGenericRelease

readableStreamTee

resetQueue

setFunctionName

setPromiseIsHandledToTrue

setUpReadableByteStreamControllerFromUnderlyingSource

setUpReadableStreamDefaultControllerFromUnderlyingSource

setUpTransformStreamDefaultControllerFromTransformer

setUpWritableStreamDefaultControllerFromUnderlyingSink

transformStreamDefaultControllerEnqueue

transformStreamDefaultControllerError

transformStreamDefaultControllerTerminate

validateAndNormalizeHighWaterMark

writableStreamAbort

writableStreamClose

writableStreamCloseQueuedOrInFlight

writableStreamDefaultControllerClearAlgorithms

writableStreamDefaultControllerError

writableStreamDefaultWriterAbort

writableStreamDefaultWriterClose

writableStreamDefaultWriterGetDesiredSize

writableStreamDefaultWriterRelease

writableStreamDefaultWriterWrite

class ReadableStreamDefaultControllerImpl

implements ReadableStreamDefaultController<R>

import { ReadableStreamDefaultControllerImpl } from "https://deno.land/x/deno@v1.0.0/cli/js/web/streams/readable_stream_default_controller.ts";

Constructors

new

private

ReadableStreamDefaultControllerImpl()

Type Parameters

optional

R = any

Properties

readonly

desiredSize: number | null

[sym.cancelAlgorithm]: CancelAlgorithm

[sym.closeRequested]: boolean

[sym.controlledReadableStream]: ReadableStreamImpl<R>

[sym.pullAgain]: boolean

[sym.pullAlgorithm]: PullAlgorithm

[sym.pulling]: boolean

[sym.queue]: Array<Pair<R>>

[sym.queueTotalSize]: number

[sym.started]: boolean

[sym.strategyHWM]: number

[sym.strategySizeAlgorithm]: SizeAlgorithm<R>

Methods

close(): void

enqueue(chunk: R): void

error(error?: any): void

[customInspect](): string

[sym.cancelSteps](reason?: any): PromiseLike<void>

[sym.pullSteps](): Promise<ReadableStreamReadResult<R>>