Lines Matching refs:data
50 // port1 first, then again to port2, which reads the data.
51 // Internally, this sets up a pipelined data flow that is
61 // data property of the MessageEvent, and R1 is configured to pipeTo W1.
67 // data property of the MessageEvent, and R2 is configured to pipeTo W2.
70 // to begin pulling the data. The data is then pushed along the pipeline
73 // passing data and control instructions, potentially across realms,
79 // failing the close R1's controller which signals the end of the data
89 port2.onmessage = common.mustCall(({ data }) => {
90 assert(isReadableStream(data));
92 const reader = data.getReader();
100 port1.onmessage = common.mustCall(({ data }) => {
101 assert(isReadableStream(data));
102 assert(!data.locked);
103 port1.postMessage(data, [data]);
104 assert(data.locked);
137 port2.onmessage = common.mustCall(({ data }) => {
138 assert(isReadableStream(data));
139 assert(!isReadableByteStreamController(data[kState].controller));
141 const reader = data.getReader();
149 port1.onmessage = common.mustCall(({ data }) => {
150 assert(isReadableStream(data));
151 assert(!isReadableByteStreamController(data[kState].controller));
152 assert(!data.locked);
153 port1.postMessage(data, [data]);
154 assert(data.locked);
171 // through which the data flows...
182 // When the writer on port2.onmessage writes the chunk of data, it
192 port2.onmessage = common.mustCall(({ data }) => {
193 assert(isWritableStream(data));
194 assert(!data.locked);
195 const writer = data.getWriter();
201 port1.onmessage = common.mustCall(({ data }) => {
202 assert(isWritableStream(data));
203 assert(!data.locked);
204 port1.postMessage(data, [data]);
205 assert(data.locked);
221 // The data flow here is actually quite complicated, and is a combination
251 // port1.onmessage then writes a chunk of data. That chunk of data
267 port2.onmessage = common.mustCall(({ data }) => {
268 assert(isTransformStream(data));
269 const writer = data.writable.getWriter();
270 const reader = data.readable.getReader();
285 port1.onmessage = common.mustCall(({ data }) => {
286 assert(isTransformStream(data));
287 assert(!data.readable.locked);
288 assert(!data.writable.locked);
289 port1.postMessage(data, [data]);
290 assert(data.readable.locked);
291 assert(data.writable.locked);
316 port1.onmessage = ({ data }) => {
317 const reader = data.getReader();
330 data: {},
357 data: {},
364 port1.onmessage = common.mustCall(({ data }) => {
365 const writer = data.getWriter();
397 port1.onmessage = common.mustCall(({ data }) => {
398 const writer = data.getWriter();
423 port1.onmessage = common.mustCall(({ data }) => {
424 const writer = data.getWriter();
457 parentPort.onmessage = tracker.calls(({ data }) => {
458 assert(isReadableStream(data));
459 const reader = data.getReader();
490 port1.onmessage = common.mustCall(({ data }) => {
491 data.cancel().then(common.mustCall());
512 port1.onmessage = common.mustCall(({ data }) => {
515 const reader = data.getReader();
546 port1.onmessage = common.mustCall(({ data }) => {
548 const writer = data.getWriter();