| <!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('TransformStream errors thrown in transform put the writable and readable in an errored state'); |
| test1.step(function() { |
| var promiseCalls = 0; |
| var thrownError = new Error('bad things are happening!'); |
| var ts = new TransformStream({ |
| transform: function() { |
| throw thrownError; |
| } |
| }); |
| |
| assert_equals(ts.writable.state, 'writable', 'writable starts in writable'); |
| |
| var reader = ts.readable.getReader(); |
| |
| reader.read().then( |
| test1.step_func(function() { assert_unreached('readable\'s read() should reject'); }), |
| test1.step_func(function(r) { |
| assert_equals(r, thrownError, 'readable\'s read should reject with the thrown error'); |
| assert_equals(++promiseCalls, 2); |
| }) |
| ); |
| |
| reader.closed.then( |
| test1.step_func(function() { assert_unreached('readable\'s closed should not be fulfilled'); }), |
| test1.step_func(function(e) { |
| assert_equals(e, thrownError, 'readable\'s closed should be rejected with the thrown error'); |
| assert_equals(++promiseCalls, 3); |
| test1.done(); |
| }) |
| ); |
| |
| ts.writable.closed.then( |
| test1.step_func(function() { assert_unreached('writable\'s closed should not be fulfilled'); }), |
| test1.step_func(function(e) { |
| assert_equals(e, thrownError, 'writable\'s closed should be rejected with the thrown error'); |
| assert_equals(++promiseCalls, 1); |
| }) |
| ); |
| |
| ts.writable.write('a'); |
| assert_equals(ts.writable.state, 'waiting', 'writable becomes waiting immediately after throw'); |
| }); |
| |
| var test2 = async_test('TransformStream errors thrown in flush put the writable and readable in an errored state'); |
| test2.step(function() { |
| var promiseCalls = 0; |
| var thrownError = new Error('bad things are happening!'); |
| var ts = new TransformStream({ |
| transform: function(chunk, enqueue, done) { |
| done(); |
| }, |
| flush: function() { |
| throw thrownError; |
| } |
| }); |
| |
| var reader = ts.readable.getReader(); |
| |
| reader.read().then( |
| test2.step_func(function() { assert_unreached('readable\'s read() should reject'); }), |
| test2.step_func(function(r) { |
| assert_equals(r, thrownError, 'readable\'s read should reject with the thrown error'); |
| assert_equals(++promiseCalls, 2); |
| }) |
| ); |
| |
| reader.closed.then( |
| test2.step_func(function() { assert_unreached('readable\'s closed should not be fulfilled'); }), |
| test2.step_func(function(e) { |
| assert_equals(e, thrownError, 'readable\'s closed should be rejected with the thrown error'); |
| assert_equals(++promiseCalls, 3); |
| test2.done(); |
| }) |
| ); |
| |
| ts.writable.closed.then( |
| test2.step_func(function() { assert_unreached('writable\'s closed should not be fulfilled'); }), |
| test2.step_func(function(e) { |
| assert_equals(e, thrownError, 'writable\'s closed should be rejected with the thrown error'); |
| assert_equals(++promiseCalls, 1); |
| }) |
| ); |
| |
| assert_equals(ts.writable.state, 'writable', 'writable starts in writable'); |
| ts.writable.write('a'); |
| assert_equals(ts.writable.state, 'waiting', 'writable becomes waiting after a write'); |
| ts.writable.close(); |
| assert_equals(ts.writable.state, 'closing', 'writable becomes closing after the close call'); |
| }); |
| </script> |
