<!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 with no options and a destination error');
test1.step(function() {
    var cancelCalled = false;
    var theError = new Error('destination error');
    var rs = new ReadableStream({
        start: function(c) {
            c.enqueue('a');
            setTimeout(test1.step_func(function() { c.enqueue('b'); }), 200);
            setTimeout(test1.step_func(function() {
                assert_throws(new TypeError(), function() { c.enqueue('c'); }); // Enqueue after cancel should throw.
                assert_true(cancelCalled);
                test1.done();
            }), 500);
        },
        cancel: function(r) {
            assert_equals(r, theError, 'reason passed to cancel equals the source error');
            cancelCalled = true;
        }
    });

    var ws = new WritableStream({
        write: function(chunk) {
            if (chunk === 'b') {
                throw theError;
            }
        }
    });

    rs.pipeTo(ws);
});

var test2 = async_test('Piping with { preventCancel: false } and a destination error');
test2.step(function() {
    var cancelCalled = false;
    var theError = new Error('destination error');
    var rs = new ReadableStream({
        start: function(c) {
            c.enqueue('a');
            setTimeout(test2.step_func(function() { c.enqueue('b'); }), 200);
            setTimeout(test2.step_func(function() {
                assert_throws(new TypeError(), function() { c.enqueue('c'); }); // Enqueue after cancel should throw.
                assert_true(cancelCalled);
                test2.done();
            }), 500);
        },
        cancel: function(r) {
            assert_equals(r, theError, 'reason passed to cancel equals the source error');
            cancelCalled = true;
        }
    });

    var ws = new WritableStream({
        write: function(chunk) {
            if (chunk === 'b') {
                throw theError;
            }
        }
    });

    rs.pipeTo(ws, { preventCancel: false });
});

var test3 = async_test('Piping with { preventCancel: true } and a destination error');
test3.step(function() {
    var theError = new Error('destination error');
    var rs = new ReadableStream({
        start: function(c) {
            c.enqueue('a');
            setTimeout(test3.step_func(function() { c.enqueue('b'); }), 200);
            setTimeout(test3.step_func(function() { c.enqueue('c'); }), 400);
            setTimeout(test3.step_func(function() { c.enqueue('d'); }), 600);
        },
        cancel: function(r) {
            assert_unreached('unexpected call to cancel');
        }
    });

    var ws = new WritableStream({
        write: function(chunk) {
            if (chunk === 'b') {
                throw theError;
            }
        }
    });

    rs.pipeTo(ws, { preventCancel: true }).catch(test3.step_func(function(e) {
        assert_equals(e, theError, 'rejection reason of pipeTo promise is the sink error');

        var reader;
        reader = rs.getReader(); // Should be able to get a stream reader after pipeTo completes.

        // { value: 'c', done: false } gets consumed before we know that ws has errored, and so is lost.

        return reader.read().then(test3.step_func(function(result) {
            assert_object_equals(result, { value: 'd', done: false }, 'should be able to read the remaining chunk from the reader');
            test3.done();
        }));
    })).catch(test3.step_func(function(e) { assert_unreached(e); }));
});
</script>