| /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-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-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-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-tls-socket-allow-half-open-option.js | 24 const duplex = new stream.Duplex({ constant
28 const socket = new tls.TLSSocket(duplex, { allowHalfOpen: true });
|
| /third_party/node/deps/npm/node_modules/duplexer3/ |
| D | README.md | 32 var duplex = duplexer3(writable, readable);
34 duplex.on("data", function(e) {
38 duplex.on("finish", function() {
42 duplex.on("end", function() {
46 duplex.write("oh, hi there", function() {
50 duplex.end(function() {
91 const duplex = duplexer3(new stream.Writable(), new stream.Readable());
|
| /third_party/node/deps/npm/lib/utils/ |
| D | gunzip-maybe.js | 1 var duplex = require('mississippi').duplex variable
11 var stream = duplex()
|
| /third_party/node/deps/npm/node_modules/is-stream/ |
| D | index.js | 15 isStream.duplex = function (stream) { function
20 …return isStream.duplex(stream) && typeof stream._transform === 'function' && typeof stream._transf…
|
| D | readme.md | 35 #### isStream.duplex(stream)
|
| /third_party/node/deps/npm/node_modules/duplexify/ |
| D | README.md | 3 Turn a writeable and readable stream into a single streams2 duplex stream.
21 // turn writableStream and readableStream into a single duplex stream
58 console.log('the duplex stream is destroyed')
66 Turn a node core http request into a duplex stream is as easy as
|
| /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/deps/npm/node_modules/pumpify/ |
| D | README.md | 3 Combine an array of streams into a single duplex stream using [pump](https://github.com/mafintosh/p…
15 `pipeline` is a duplex stream that writes to the first streams and reads from the last one.
|
| /third_party/node/deps/npm/node_modules/mississippi/ |
| D | readme.md | 18 - [duplex](#duplex)
130 ### duplex subsection
132 ##### `var duplex = miss.duplex([writable, readable, opts])` argument
134 Take two separate streams, a writable and a readable, and turn them into a single [duplex (readable…
142 `miss.duplex` is provided by [`require('duplexify')`](https://www.npmjs.com/package/duplexify)
154 var duplexCurl = miss.duplex(curl.stdin, curl.stdout)
|
| D | index.js | 4 module.exports.duplex = require('duplexify')
|
| /third_party/python/Lib/multiprocessing/ |
| D | connection.py | 521 def Pipe(duplex=True): argument
525 if duplex:
540 def Pipe(duplex=True): argument
545 if duplex:
575 c1 = PipeConnection(h1, writable=duplex)
576 c2 = PipeConnection(h2, readable=duplex)
|
| D | context.py | 60 def Pipe(self, duplex=True): argument
63 return Pipe(duplex)
|
| D | queues.py | 42 self._reader, self._writer = connection.Pipe(duplex=False)
341 self._reader, self._writer = connection.Pipe(duplex=False)
|
| /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()
|
| /third_party/boost/libs/asio/doc/overview/ |
| D | allocation.qbk | 15 asynchronous operations. A half duplex protocol implementation (e.g. an HTTP
17 by sends). A full duplex protocol implementation would have two chains
|
| /third_party/python/Lib/multiprocessing/dummy/ |
| D | connection.py | 46 def Pipe(duplex=True): argument
|
| /third_party/boost/libs/beast/doc/qbk/07_concepts/ |
| D | Streams.qbk | 12 A stream in the context of Beast and networking, represents a full-duplex
|
| /third_party/pulseaudio/ |
| D | todo | 33 - examine if it is possible to mimic esd's handling of half duplex cards
|
| /third_party/node/deps/npm/node_modules/end-of-stream/ |
| D | README.md | 3 A node module that calls a callback when a readable/writable/duplex stream has completed or failed.
|
| /third_party/pulseaudio/src/modules/alsa/mixer/profile-sets/ |
| D | maudio-fasttrack-pro.conf | 18 ; This card has one duplex stereo channel called A and an additional
|
| /third_party/skia/third_party/externals/oboe/apps/OboeTester/docs/ |
| D | AutomatedTesting.md | 137 …reset.count = 2 # number of times the full duplex stream input underflowed and had to resync…
164 …reset.count = 208 # number of times the full duplex stream input underflowed and had to res…
|