Searched refs:writer1 (Results 1 – 9 of 9) sorted by relevance
/third_party/node/test/parallel/ |
D | test-stream-pipe-cleanup-pause.js | 6 const writer1 = new stream.Writable(); constant 16 writer1._write = common.mustCall(function(chunk, encoding, cb) { 20 writer1.once('chunk-received', function() { 21 reader.unpipe(writer1); 36 reader.pipe(writer1);
|
D | test-stream-pipe-await-drain.js | 9 const writer1 = new stream.Writable(); constant 20 writer1._write = common.mustCall(function(chunk, encoding, cb) { 25 writer1.once('chunk-received', () => { 64 reader.pipe(writer1);
|
D | test-webstreams-abort-controller.js | 152 const writer1 = ws1.getWriter(); constant 157 assert.rejects(writer1.write('a'), /AbortError/).then(common.mustCall()); 158 assert.rejects(writer1.closed, /AbortError/).then(common.mustCall());
|
/third_party/node/test/fixtures/wpt/streams/writable-streams/ |
D | general.any.js | 173 const writer1 = ws1.getWriter(); constant 174 writer1.write('a'); 175 writer1.close(); 196 return writer1.closed 218 const writer1 = ws.getWriter(); constant 219 assert_equals(undefined, writer1.releaseLock(), 'releaseLock() should return undefined'); 221 assert_equals(undefined, writer1.releaseLock(), 'no-op releaseLock() should return undefined');
|
D | reentrant-strategy.any.js | 148 let writer1; variable 156 writer1.releaseLock(); 166 writer1 = ws.getWriter(); 167 …const writePromise1 = promise_rejects_js(t, TypeError, writer1.write(1), 'write() promise should r… 168 …const readyPromise = promise_rejects_js(t, TypeError, writer1.ready, 'ready promise should reject'… 169 …const closedPromise1 = promise_rejects_js(t, TypeError, writer1.closed, 'closed promise should rej…
|
D | close.any.js | 405 const writer1 = ws.getWriter(); constant 406 return writer1.close().then(() => { 407 writer1.releaseLock();
|
/third_party/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_rwlock_unlock/ |
D | 3-1.c | 191 pthread_t writer1, reader, writer2; in main() local 216 if (pthread_create(&writer1, NULL, fn_wr_1, (void *)(long)priority) != in main() 317 if (pthread_join(writer1, NULL) != 0) { in main()
|
/third_party/icu/ohos_icu4j/src/main/tests/ohos/global/icu/dev/test/timezone/ |
D | TimeZoneRuleTest.java | 471 OutputStreamWriter writer1 = new OutputStreamWriter(baos1); in TestVTimeZoneRoundTrip() local 472 vtz_new.write(writer1); in TestVTimeZoneRoundTrip() 473 writer1.close(); in TestVTimeZoneRoundTrip()
|
/third_party/icu/icu4j/main/tests/core/src/com/ibm/icu/dev/test/timezone/ |
D | TimeZoneRuleTest.java | 469 OutputStreamWriter writer1 = new OutputStreamWriter(baos1); in TestVTimeZoneRoundTrip() local 470 vtz_new.write(writer1); in TestVTimeZoneRoundTrip() 471 writer1.close(); in TestVTimeZoneRoundTrip()
|