| /third_party/node/test/parallel/ |
| D | test-stream-duplex-destroy.js | 8 const duplex = new Duplex({ constant
13 duplex.resume();
15 duplex.on('end', common.mustNotCall());
16 duplex.on('finish', common.mustNotCall());
17 duplex.on('close', common.mustCall());
19 duplex.destroy();
20 assert.strictEqual(duplex.destroyed, true);
24 const duplex = new Duplex({ constant
28 duplex.resume();
32 duplex.on('end', common.mustNotCall());
[all …]
|
| D | test-whatwg-webstreams-adapters-to-readablewritablepair.js | 20 const duplex = new PassThrough(); constant
24 } = newReadableWritablePairFromDuplex(duplex);
37 duplex.destroy();
39 duplex.on('close', common.mustCall());
47 const duplex = new PassThrough(); constant
51 } = newReadableWritablePairFromDuplex(duplex);
53 duplex.on('close', common.mustCall());
54 duplex.on('error', common.mustCall((reason) => {
64 duplex.destroy(error);
69 const duplex = new PassThrough(); constant
[all …]
|
| D | test-whatwg-webstreams-adapters-to-streamduplex.js | 29 const duplex = newStreamDuplexFromReadableWritablePair(transform); constant
34 duplex.destroy();
36 duplex.on('close', common.mustCall(() => {
45 const duplex = newStreamDuplexFromReadableWritablePair(transform); constant
50 duplex.destroy(error);
51 duplex.on('error', common.mustCall((reason) => {
55 duplex.on('close', common.mustCall(() => {
64 const duplex = new newStreamDuplexFromReadableWritablePair(transform); constant
66 duplex.end();
67 duplex.resume();
[all …]
|
| D | test-stream-duplex-readable-writable.js | 8 const duplex = new Duplex({ constant
11 assert.strictEqual(duplex.readable, false);
12 duplex.push('asd');
13 duplex.on('error', common.mustCall((err) => {
16 duplex.on('data', common.mustNotCall());
17 duplex.on('end', common.mustNotCall());
21 const duplex = new Duplex({ constant
25 assert.strictEqual(duplex.writable, false);
26 duplex.write('asd');
27 duplex.on('error', common.mustCall((err) => {
[all …]
|
| D | test-stream-duplex-from.js | 152 const duplex = new Duplex(); constant
153 assert.strictEqual(Duplex.from(duplex), duplex);
160 const duplex = Duplex.from(blob); constant
161 duplex.on('data', common.mustCall((arrayBuffer) => {
198 const duplex = Duplex.from({ constant
209 assert.strictEqual(duplex.writable, false);
215 const duplex = Duplex.from({ constant
223 duplex.write(msg);
224 assert.strictEqual(duplex.readable, false);
231 const duplex = Duplex.from({ constant
[all …]
|
| D | test-stream-duplex-writable-finished.js | 15 const duplex = new Duplex(); constant
17 duplex._write = (chunk, encoding, cb) => {
19 assert.strictEqual(duplex.writableFinished, false);
23 duplex.on('finish', common.mustCall(() => {
24 assert.strictEqual(duplex.writableFinished, true);
27 duplex.end('testing finished state', common.mustCall(() => {
28 assert.strictEqual(duplex.writableFinished, true);
|
| D | test-stream-duplex.js | 76 const duplex = Duplex.fromWeb(pair); constant
78 duplex.write(dataToWrite);
79 duplex.once('data', common.mustCall((chunk) => {
105 const duplex = Duplex.fromWeb(pair, { encoding: 'utf8', objectMode: true }); constant
107 duplex.write(dataToWrite);
108 duplex.once('data', common.mustCall((chunk) => {
117 const duplex = Duplex({ constant
127 const { writable, readable } = Duplex.toWeb(duplex);
|
| D | test-stream-inheritance.js | 8 const duplex = new Duplex({ read() {}, write() {} }); constant
13 assert.ok(duplex instanceof Readable);
18 assert.ok(duplex instanceof Writable);
23 assert.ok(duplex instanceof Duplex);
28 assert.ok(!(duplex instanceof Transform));
|
| D | test-whatwg-webstreams-adapters-to-writablestream.js | 140 const duplex = new PassThrough(); constant
141 duplex.setEncoding('utf8');
142 const writableStream = newWritableStreamFromStreamWritable(duplex);
149 duplex.on('data', common.mustCall((chunk) => {
163 const duplex = new Duplex({ writable: false }); constant
164 const writableStream = newWritableStreamFromStreamWritable(duplex);
|
| D | test-stream-pipeline-queued-end-in-destroy.js | 15 const duplex = new Duplex({ constant
28 duplex.on('finished', common.mustNotCall());
30 pipeline(readable, duplex, common.mustCall((err) => {
|
| D | test-stream-readable-aborted.js | 60 const duplex = new Duplex({ constant
64 duplex.destroy();
65 assert.strictEqual(duplex.readableAborted, false);
|
| D | test-tls-socket-allow-half-open-option.js | 24 const duplex = new stream.Duplex({ constant
28 const socket = new tls.TLSSocket(duplex, { allowHalfOpen: true });
|
| D | test-whatwg-webstreams-adapters-to-readablestream.js | 199 const duplex = new Duplex({ readable: false }); constant
200 duplex.destroy();
201 const readableStream = newReadableStreamFromStreamReadable(duplex);
|
| D | test-stream-pipeline.js | 1458 const duplex = new PassThrough();
1462 await pipelinePromise(read, duplex);
1464 assert.strictEqual(duplex.destroyed, false);
1478 const duplex = new PassThrough();
1482 await pipelinePromise(read, duplex, { end: false });
1484 assert.strictEqual(duplex.destroyed, false);
1485 assert.strictEqual(duplex.writableEnded, false);
|
| /third_party/node/lib/internal/webstreams/ |
| D | adapters.js | 571 function newReadableWritablePairFromDuplex(duplex) { argument
578 if (typeof duplex?._writableState !== 'object' ||
579 typeof duplex?._readableState !== 'object') {
580 throw new ERR_INVALID_ARG_TYPE('duplex', 'stream.Duplex', duplex);
583 if (isDestroyed(duplex)) {
592 isWritable(duplex) ?
593 newWritableStreamFromStreamWritable(duplex) :
596 if (!isWritable(duplex))
600 isReadable(duplex) ?
601 newReadableStreamFromStreamReadable(duplex) :
[all …]
|
| /third_party/cups-filters/filter/ |
| D | pcl-common.h | 40 #define pcl_set_duplex(duplex,landscape)\ argument
41 if (duplex) printf("\033&l%dS", (duplex) + (landscape))
|
| D | urftopdf.cpp | 267 uint8_t duplex; member
461 page_header.duplex = page_header_orig.duplex; in main()
474 iprintf("Duplex Mode : %d\n", page_header.duplex); in main()
|
| /third_party/cups-filters/cupsfilters/ |
| D | ppdgenerator.h | 65 const char *pdl, int color, int duplex);
68 const char *pdl, int color, int duplex,
|
| /third_party/python/Lib/asyncio/ |
| D | windows_utils.py | 32 def pipe(*, duplex=False, overlapped=(True, True), bufsize=BUFSIZE): argument
38 if duplex:
136 stdin_rh, stdin_wh = pipe(overlapped=(False, True), duplex=True)
|
| /third_party/node/lib/internal/streams/ |
| D | duplex.js | 136 Duplex.toWeb = function(duplex) { argument
137 return lazyWebStreams().newReadableWritablePairFromDuplex(duplex);
|
| /third_party/cups-filters/filter/pdftopdf/ |
| D | pdftopdf_processor.h | 25 duplex(false), in ProcessingParameters()
72 bool duplex; member
|
| /third_party/typescript/scripts/build/ |
| D | utils.mjs | 216 duplex.push(file);
221 const duplex = new Duplex({
253 const endThenCb = () => (duplex.push(null), cb()); // signal end of read queue
267 return duplex;
|
| /third_party/node/deps/undici/src/types/ |
| D | fetch.d.ts | 118 duplex?: RequestDuplex
154 readonly duplex: RequestDuplex
|
| /third_party/python/Lib/multiprocessing/ |
| D | connection.py | 516 def Pipe(duplex=True): argument
520 if duplex:
535 def Pipe(duplex=True): argument
540 if duplex:
570 c1 = PipeConnection(h1, writable=duplex)
571 c2 = PipeConnection(h2, readable=duplex)
|
| /third_party/skia/third_party/externals/swiftshader/third_party/llvm-10.0/llvm/lib/Target/Hexagon/MCTargetDesc/ |
| D | HexagonShuffler.cpp | 306 unsigned duplex = 0; in check() local
399 ++duplex; in check()
421 (duplex > 1 || (duplex && memory))) { in check()
|