stream.Duplex.fromWeb(pair[, options])

• pair <Object>

  • readable <ReadableStream>

  • writable <WritableStream>

• options <Object>

  • allowHalfOpen <boolean>

  • decodeStrings <boolean>

  • encoding <string>

  • highWaterMark <number>

  • objectMode <boolean>

  • signal <AbortSignal>

• 返回:<stream.Duplex>

  \Returns: <stream.Duplex>

import { Duplex } from 'node:stream';
import {
 ReadableStream,
 WritableStream,
} from 'node:stream/web';
const readable = new ReadableStream({
 start(controller) {
 controller.enqueue('world');
 },
});
const writable = new WritableStream({
 write(chunk) {
 console.log('writable', chunk);
 },
});
const pair = {
 readable,
 writable,
};
const duplex = Duplex.fromWeb(pair, { encoding: 'utf8', objectMode: true });
duplex.write('hello');
for await (const chunk of duplex) {
 console.log('readable', chunk);
}const { Duplex } = require('node:stream');
const {
 ReadableStream,
 WritableStream,
} = require('node:stream/web');
const readable = new ReadableStream({
 start(controller) {
 controller.enqueue('world');
 },
});
const writable = new WritableStream({
 write(chunk) {
 console.log('writable', chunk);
 },
});
const pair = {
 readable,
 writable,
};
const duplex = Duplex.fromWeb(pair, { encoding: 'utf8', objectMode: true });
duplex.write('hello');
duplex.once('readable', () => console.log('readable', duplex.read()));拷贝