Потоки
Управление потоками данных, стратегиями организации очередей и преобразованиями. Обрабатывайте данные фрагментами, большие наборы данных и оптимизируйте использование памяти.
Например, ReadableStream, WritableStream, TransformStream
интерфейс ByteLengthQueuingStrategy
Свойства
highWaterMark: number size: QueuingStrategySize<ArrayBufferView> переменная ByteLengthQueuingStrategy
Объект-конструктор для ByteLengthQueuingStrategy, используемый для создания стратегии организации очереди, которая оценивает каждый фрагмент по его byteLength относительно верхнего порога потока.
Свойства
prototype: ByteLengthQueuingStrategy интерфейс CompressionStream
API для сжатия потока данных.
Примеры
await Deno.stdin.readable
.pipeThrough(new CompressionStream("gzip"))
.pipeTo(Deno.stdout.writable);
Свойства
readable: ReadableStream<Uint8Array<ArrayBuffer>> writable: WritableStream<BufferSource> переменная CompressionStream
API для сжатия потока данных.
Примеры
await Deno.stdin.readable
.pipeThrough(new CompressionStream("gzip"))
.pipeTo(Deno.stdout.writable);
Свойства
prototype: CompressionStream интерфейс CountQueuingStrategy
Этот интерфейс Streams API предоставляет встроенную стратегию организации очереди, основанную на длине в байтах, которую можно использовать при создании потоков.
Свойства
highWaterMark: number size: QueuingStrategySize переменная CountQueuingStrategy
Объект-конструктор для CountQueuingStrategy, используемый для создания стратегии организации очереди, которая учитывает каждый фрагмент как одну единицу относительно верхнего порога потока.
Свойства
prototype: CountQueuingStrategy интерфейс DecompressionStream
API для распаковки потока данных.
Примеры
const input = await Deno.open("./file.txt.gz");
const output = await Deno.create("./file.txt");
await input.readable
.pipeThrough(new DecompressionStream("gzip"))
.pipeTo(output.writable);
Свойства
readable: ReadableStream<Uint8Array<ArrayBuffer>> writable: WritableStream<BufferSource> переменная DecompressionStream
API для распаковки потока данных.
Примеры
const input = await Deno.open("./file.txt.gz");
const output = await Deno.create("./file.txt");
await input.readable
.pipeThrough(new DecompressionStream("gzip"))
.pipeTo(output.writable);
Свойства
prototype: DecompressionStream интерфейс GenericTransformStream
Свойства
readable: ReadableStream writable: WritableStream интерфейс QueuingStrategy
Параметры типа
T = any Свойства
highWaterMark: number size: QueuingStrategySize<T> интерфейс QueuingStrategyInit
Свойства
highWaterMark: number интерфейс QueuingStrategySize
Параметры типа
T = any Сигнатуры вызова
(chunk: T): number интерфейс ReadableByteStreamController
Свойства
byobRequest: ReadableStreamBYOBRequest | null desiredSize: number | null Методы
переменная ReadableByteStreamController
Объект-конструктор для ReadableByteStreamController.
Экземпляры передаются в функции обратного вызова базового источника ReadableStream, ориентированного на байты, а не создаются напрямую, поэтому вызов конструктора приводит к исключению.
Свойства
prototype: ReadableByteStreamController интерфейс ReadableStream
Этот интерфейс Streams API представляет читаемый поток байтовых данных. Fetch API предоставляет экземпляр ReadableStream через свойство body объекта Response.
Параметры типа
R = any Свойства
locked: boolean Методы
cancel(reason?: any): Promise<void> getReader(options: { mode: "byob"; }): ReadableStreamBYOBReader getReader(options?: ReadableStreamGetReaderOptions): ReadableStreamReader<R> pipeThrough<T>(
transform: ReadableWritablePair<T, R>,
options?: StreamPipeOptions,
): ReadableStream<T> pipeTo(
destination: WritableStream<R>,
options?: StreamPipeOptions,
): Promise<void> tee(): [ReadableStream<R>, ReadableStream<R>] values(options?: ReadableStreamIteratorOptions): AsyncIterableIterator<R> [[Symbol.asyncIterator]](options?: ReadableStreamIteratorOptions): AsyncIterableIterator<R> переменная ReadableStream
Объект-конструктор для ReadableStream, используемый для создания читаемого потока на основе базового источника, описывающего, как данные помещаются в очередь и считываются.
Свойства
prototype: ReadableStream Методы
from<R>(asyncIterable: AsyncIterable<R> | Iterable<R | PromiseLike<R>> & object): ReadableStream<R> интерфейс ReadableStreamBYOBReader
Методы
read<T extends ArrayBufferView>(
view: T,
options?: ReadableStreamBYOBReaderReadOptions,
): Promise<ReadableStreamReadResult<T>> releaseLock(): void переменная ReadableStreamBYOBReader
Объект-конструктор для ReadableStreamBYOBReader, используемый для создания средства чтения «со своим буфером», привязанного к заданному байтовому потоку. Большинство программ получают его с помощью ReadableStream.getReader({ mode: "byob" }).
Свойства
prototype: ReadableStreamBYOBReader интерфейс ReadableStreamBYOBReaderReadOptions
Свойства
min: number интерфейс ReadableStreamBYOBRequest
Свойства
view: Uint8Array<ArrayBuffer> | null Методы
respond(bytesWritten: number): void respondWithNewView(view: ArrayBufferView): void переменная ReadableStreamBYOBRequest
Объект-конструктор для ReadableStreamBYOBRequest.
Экземпляры передаются контроллеру байтового потока, а не создаются напрямую, поэтому вызов конструктора приводит к исключению.
Свойства
prototype: ReadableStreamBYOBRequest интерфейс ReadableStreamDefaultController
переменная ReadableStreamDefaultController
Объект-конструктор для ReadableStreamDefaultController.
Экземпляры передаются в функции обратного вызова базового источника ReadableStream, а не создаются напрямую, поэтому вызов конструктора приводит к исключению.
Свойства
prototype: ReadableStreamDefaultController интерфейс ReadableStreamDefaultReader
Параметры типа
R = any Методы
read(): Promise<ReadableStreamReadResult<R>> releaseLock(): void переменная ReadableStreamDefaultReader
Объект-конструктор для ReadableStreamDefaultReader, используемый для создания читателя по умолчанию, заблокированного на указанном ReadableStream. Обычно код получает его через ReadableStream.getReader.
Свойства
prototype: ReadableStreamDefaultReader интерфейс ReadableStreamGenericReader
интерфейс ReadableStreamGetReaderOptions
Свойства
mode: ReadableStreamReaderMode интерфейс ReadableStreamIteratorOptions
Свойства
preventCancel: boolean интерфейс ReadableStreamReadDoneResult
интерфейс ReadableStreamReadValueResult
интерфейс ReadableWritablePair
Параметры типа
R = any W = any Свойства
интерфейс StreamPipeOptions
Свойства
preventAbort: boolean preventCancel: boolean preventClose: boolean signal: AbortSignal интерфейс Transformer
Параметры типа
I = any O = any Свойства
flush: TransformerFlushCallback<O> readableType: undefined start: TransformerStartCallback<O> transform: TransformerTransformCallback<I, O> cancel: TransformerCancelCallback writableType: undefined интерфейс TransformerCancelCallback
Сигнатуры вызова
(reason: any): void | PromiseLike<void> интерфейс TransformerFlushCallback
Параметры типа
O Сигнатуры вызова
(controller: TransformStreamDefaultController<O>): void | PromiseLike<void> интерфейс TransformerStartCallback
Параметры типа
O Сигнатуры вызова
(controller: TransformStreamDefaultController<O>): any интерфейс TransformerTransformCallback
Параметры типа
I O Сигнатуры вызова
(
chunk: I,
controller: TransformStreamDefaultController<O>,
): void | PromiseLike<void> интерфейс TransformStream
Параметры типа
I = any O = any Свойства
readable: ReadableStream<O> writable: WritableStream<I> переменная TransformStream
Объект-конструктор для TransformStream, используемый для создания потока преобразования из трансформера, описывающего, как фрагменты данных, считанные с его записываемой стороны, преобразуются перед появлением на его читаемой стороне.
Свойства
prototype: TransformStream интерфейс TransformStreamDefaultController
переменная TransformStreamDefaultController
Объект-конструктор для TransformStreamDefaultController.
Экземпляры передаются в функции обратного вызова трансформера TransformStream, а не создаются напрямую, поэтому вызов конструктора приводит к ошибке.
Свойства
prototype: TransformStreamDefaultController интерфейс UnderlyingByteSource
Свойства
autoAllocateChunkSize: number cancel: UnderlyingSourceCancelCallback pull: (controller: ReadableByteStreamController) => void | PromiseLike<void> start: (controller: ReadableByteStreamController) => any type: "bytes" интерфейс UnderlyingDefaultSource
Параметры типа
R = any Свойства
cancel: UnderlyingSourceCancelCallback pull: (controller: ReadableStreamDefaultController<R>) => void | PromiseLike<void> start: (controller: ReadableStreamDefaultController<R>) => any type: undefined интерфейс UnderlyingSink
Параметры типа
W = any Свойства
abort: UnderlyingSinkAbortCallback close: UnderlyingSinkCloseCallback start: UnderlyingSinkStartCallback type: undefined write: UnderlyingSinkWriteCallback<W> интерфейс UnderlyingSinkAbortCallback
Сигнатуры вызова
(reason?: any): void | PromiseLike<void> интерфейс UnderlyingSinkCloseCallback
Сигнатуры вызова
(): void | PromiseLike<void> интерфейс UnderlyingSinkStartCallback
Сигнатуры вызова
(controller: WritableStreamDefaultController): any интерфейс UnderlyingSinkWriteCallback
Параметры типа
W Сигнатуры вызова
(
chunk: W,
controller: WritableStreamDefaultController,
): void | PromiseLike<void> интерфейс UnderlyingSource
Параметры типа
R = any Свойства
autoAllocateChunkSize: number cancel: UnderlyingSourceCancelCallback pull: UnderlyingSourcePullCallback<R> start: UnderlyingSourceStartCallback<R> type: ReadableStreamType интерфейс UnderlyingSourceCancelCallback
Сигнатуры вызова
(reason?: any): void | PromiseLike<void> интерфейс UnderlyingSourcePullCallback
Параметры типа
R Сигнатуры вызова
(controller: ReadableStreamController<R>): void | PromiseLike<void> интерфейс UnderlyingSourceStartCallback
Параметры типа
R Сигнатуры вызова
(controller: ReadableStreamController<R>): any интерфейс WritableStream
Этот интерфейс Streams API предоставляет стандартную абстракцию для записи потоковых данных в назначение, называемое приемником. Этот объект имеет встроенные механизмы обратного давления и постановки в очередь.
Параметры типа
W = any Свойства
locked: boolean Методы
переменная WritableStream
Объект-конструктор для WritableStream, используемый для создания потока записи на основе нижележащего приемника, описывающего обработку записываемых фрагментов.
Свойства
prototype: WritableStream интерфейс WritableStreamDefaultController
Этот интерфейс Streams API представляет контроллер, позволяющий управлять состоянием WritableStream. При создании WritableStream нижележащему приемнику передается соответствующий экземпляр WritableStreamDefaultController для управления.
Свойства
signal: AbortSignal Методы
error(e?: any): void переменная WritableStreamDefaultController
Объект-конструктор для WritableStreamDefaultController.
Экземпляры передаются в функции обратного вызова нижележащего приемника объекта WritableStream, а не создаются напрямую, поэтому вызов конструктора приводит к исключению.
Свойства
prototype: WritableStreamDefaultController интерфейс WritableStreamDefaultWriter
Этот интерфейс Streams API представляет объект, возвращаемый методом WritableStream.getWriter(). После создания он блокирует WritableStream для < писателя, гарантируя, что никакие другие потоки не смогут выполнять запись в нижележащий приемник.
Параметры типа
W = any Свойства
closed: Promise<void> desiredSize: number | null ready: Promise<void> Методы
переменная WritableStreamDefaultWriter
Объект-конструктор для WritableStreamDefaultWriter, используемый для создания писателя, блокирующего указанный WritableStream. Обычно код получает его с помощью WritableStream.getWriter.
Свойства
prototype: WritableStreamDefaultWriter псевдоним типа CompressionFormat
Определение
"deflate"
| "deflate-raw"
| "gzip"
| "brotli"
псевдоним типа ReadableStreamController
Параметры типа
T Определение
псевдоним типа ReadableStreamReader
Параметры типа
T Определение
псевдоним типа ReadableStreamReaderMode
Определение
"byob" псевдоним типа ReadableStreamReadResult
Параметры типа
T Определение
псевдоним типа ReadableStreamType
Определение
"bytes"
© 2018–2025 the Deno authors
Licensed under the MIT License.
https://docs.deno.com/api/web/streams