(t, stream, subprocess)
| 365 | test('.duplex() can buffer data', testBufferData, 'duplex'); |
| 366 | |
| 367 | const assertDataEvents = async (t, stream, subprocess) => { |
| 368 | const [output] = await once(stream, 'data'); |
| 369 | t.is(output.toString(), foobarString); |
| 370 | |
| 371 | await finishedStream(stream); |
| 372 | await assertSubprocessOutput(t, subprocess); |
| 373 | }; |
| 374 | |
| 375 | test('.readable() can be read with "data" events', async t => { |
| 376 | const subprocess = getReadableSubprocess(); |
no test coverage detected