stream/consumers

Вспомогательные функции-потребители предоставляют стандартные способы чтения потоков.

import * as mod from "node:stream/consumers";

функция arrayBuffer

import { arrayBuffer } from "node:stream/consumers";

arrayBuffer(stream: 
WebReadableStream
 | ReadableStream
 | AsyncIterable<any>
): Promise<ArrayBuffer>

stream: 
WebReadableStream
 | ReadableStream
 | AsyncIterable<any>

Promise<ArrayBuffer>

Выполняется с ArrayBuffer, содержащим всё содержимое потока.

import { blob } from "node:stream/consumers";

blob(stream: 
WebReadableStream
 | ReadableStream
 | AsyncIterable<any>
): Promise<NodeBlob>

stream: 
WebReadableStream
 | ReadableStream
 | AsyncIterable<any>

Promise<NodeBlob>

Выполняется с Blob, содержащим всё содержимое потока.

import { buffer } from "node:stream/consumers";

buffer(stream: 
WebReadableStream
 | ReadableStream
 | AsyncIterable<any>
): Promise<Buffer>

stream: 
WebReadableStream
 | ReadableStream
 | AsyncIterable<any>

Promise<Buffer>

Выполняется с Buffer, содержащим всё содержимое потока.

import { json } from "node:stream/consumers";

json(stream: 
WebReadableStream
 | ReadableStream
 | AsyncIterable<any>
): Promise<unknown>

stream: 
WebReadableStream
 | ReadableStream
 | AsyncIterable<any>

Promise<unknown>

Выполняется с содержимым потока, преобразованным в строку в кодировке UTF-8, которая затем передаётся в JSON.parse().

import { text } from "node:stream/consumers";

text(stream: 
WebReadableStream
 | ReadableStream
 | AsyncIterable<any>
): Promise<string>

stream: 
WebReadableStream
 | ReadableStream
 | AsyncIterable<any>

Promise<string>

Выполняется с содержимым потока, преобразованным в строку в кодировке UTF-8.