| <!DOCTYPE html> |
| <script src='../../resources/testharness.js'></script> |
| <script src='../../resources/testharnessreport.js'></script> |
| <script src='resources/streams-utils.js'></script> |
| <script> |
| // This is updated till https://github.com/whatwg/streams/commit/4ba861e6f60c248060811830e11271c84b439cc3 |
| |
| var test1 = async_test('Piping through a duck-typed pass-through transform stream works'); |
| test1.step(function() { |
| var readableEnd = sequentialReadableStream(5).pipeThrough(duckTypedPassThroughTransform()); |
| |
| readableStreamToArray(readableEnd).then(function(chunks) { |
| assert_array_equals(chunks, [1, 2, 3, 4, 5]); |
| test1.done(); |
| }).catch(function(e) { assert_unreached(e); }); |
| }); |
| |
| var test2 = async_test('Piping through an identity transform stream will close the destination when the source closes'); |
| test2.step(function() { |
| var rs = new ReadableStream({ |
| start: function(c) { |
| c.enqueue('a'); |
| c.enqueue('b'); |
| c.enqueue('c'); |
| c.close(); |
| } |
| }); |
| |
| var ts = new TransformStream({ |
| transform: function(chunk, enqueue, done) { |
| enqueue(chunk); |
| done(); |
| } |
| }); |
| |
| var ws = new WritableStream(); |
| |
| rs.pipeThrough(ts).pipeTo(ws).then(function() { |
| assert_equals(ws.state, 'closed', 'the writable stream was closed'); |
| test2.done(); |
| }).catch(function(e) { assert_unreached(e); }); |
| }); |
| </script> |
