<!DOCTYPE html>
<script src='../../resources/testharness.js'></script>
<script src='../../resources/testharnessreport.js'></script>
<script src='resources/streams-utils.js'></script>
<script>
const IsReadableStreamDisturbed = internals.isReadableStreamDisturbed.bind(internals);

// This is updated till https://github.com/whatwg/streams/commit/4ba861e6f60c248060811830e11271c84b439cc3

test(function() {
    var rs = new ReadableStream();

    assert_false(IsReadableStreamDisturbed(rs), 'rs should not be disturbed on construction');

    var reader = rs.getReader();
    assert_false(IsReadableStreamDisturbed(rs), 'getReader() call has no effect on whether a stream is disturbed or not');

    reader.read();
    assert_true(IsReadableStreamDisturbed(rs), 'rs should be disturbed after read() call');
}, 'IsReadableStreamDisturbed returns true for an empty non-closed stream on which read() has been called');

test(function() {
    var rs = new ReadableStream();

    assert_false(IsReadableStreamDisturbed(rs), 'rs should not be disturbed on construction');

    var reader = rs.getReader();
    assert_false(IsReadableStreamDisturbed(rs), 'getReader() call has no effect on whether a stream is disturbed or not');

    reader.cancel();
    assert_true(IsReadableStreamDisturbed(rs), 'rs should be disturbed after cancel() call');
}, 'IsReadableStreamDisturbed returns true for an empty non-closed stream on which cancel() has been called');

test(function() {
    var rs = new ReadableStream({
        start: function(c) {
            c.close();
        }
    });

    assert_false(IsReadableStreamDisturbed(rs), 'rs should not be disturbed on construction');

    var reader = rs.getReader();
    assert_false(IsReadableStreamDisturbed(rs), 'getReader() call has no effect on whether a stream is disturbed or not');

    reader.read();
    assert_true(IsReadableStreamDisturbed(rs), 'rs should be disturbed after read() call');
}, 'IsReadableStreamDisturbed returns true for a closed stream on which read() has been called');

test(function() {
    var rs = new ReadableStream({
        start: function(c) {
            c.close();
        }
    });

    assert_false(IsReadableStreamDisturbed(rs), 'rs should not be disturbed on construction');

    var reader = rs.getReader();
    assert_false(IsReadableStreamDisturbed(rs), 'getReader() call has no effect on whether a stream is disturbed or not');

    reader.cancel();
    assert_true(IsReadableStreamDisturbed(rs), 'rs should be disturbed after cancel() call');
}, 'IsReadableStreamDisturbed returns true for a closed stream on which cancel() has been called');

test(function() {
    var rs = new ReadableStream({
        start: function(c) {
            c.error(new Error('waffles'));
        }
    });

    assert_false(IsReadableStreamDisturbed(rs), 'rs should not be disturbed on construction');

    var reader = rs.getReader();
    assert_false(IsReadableStreamDisturbed(rs), 'getReader() call has no effect on whether a stream is disturbed or not');

    reader.read();
    assert_true(IsReadableStreamDisturbed(rs), 'rs should be disturbed after read() call');
}, 'IsReadableStreamDisturbed returns true for an errored stream on which read() has been called');

test(function() {
    var rs = new ReadableStream({
        start: function(c) {
            c.error(new Error('waffles'));
        }
    });

    assert_false(IsReadableStreamDisturbed(rs), 'rs should not be disturbed on construction');

    var reader = rs.getReader();
    assert_false(IsReadableStreamDisturbed(rs), 'getReader() call has no effect on whether a stream is disturbed or not');

    reader.cancel();
    assert_true(IsReadableStreamDisturbed(rs), 'rs should be disturbed after cancel() call');
}, 'IsReadableStreamDisturbed returns true for an errored stream on which cancel() has been called');
</script>