2015-12-09 13:09:20 +00:00
|
|
|
<!DOCTYPE html>
|
|
|
|
|
<script src='../resources/testharness.js'></script>
|
|
|
|
|
<script src='../resources/testharnessreport.js'></script>
|
|
|
|
|
<script src='reference-implementation/resources/streams-utils.js'></script>
|
|
|
|
|
<script>
|
2015-12-22 18:20:49 +00:00
|
|
|
// This is updated till https://github.com/whatwg/streams/commit/4ba861e6f60c248060811830e11271c84b439cc3
|
|
|
|
|
|
2016-07-27 10:40:17 +00:00
|
|
|
let ReadableStreamDefaultReader = (new ReadableStream()).getReader().constructor;
|
2015-12-09 13:09:20 +00:00
|
|
|
|
|
|
|
|
function fakeWritableStream() {
|
|
|
|
|
return {
|
|
|
|
|
get closed() { return Promise.resolve(); },
|
|
|
|
|
get ready() { return Promise.resolve(); },
|
|
|
|
|
get state() { return 'closed' },
|
|
|
|
|
abort(reason) { return Promise.resolve(); },
|
|
|
|
|
close() { return Promise.resolve(); },
|
|
|
|
|
write(chunk) { return Promise.resolve(); }
|
|
|
|
|
};
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
function realReadableStream() {
|
|
|
|
|
return new ReadableStream();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
function fakeReadableStream() {
|
|
|
|
|
return {
|
|
|
|
|
cancel: function(reason) { return Promise.resolve(); },
|
2016-07-27 10:40:17 +00:00
|
|
|
getReader: function() { return new ReadableStreamDefaultReader(new ReadableStream()); },
|
2015-12-09 13:09:20 +00:00
|
|
|
pipeThrough: function(obj, options) { return obj.readable; },
|
|
|
|
|
pipeTo: function() { return Promise.resolve(); },
|
|
|
|
|
tee: function() { return [realReadableStream(), realReadableStream()]; }
|
|
|
|
|
};
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
test(function() {
|
|
|
|
|
var pipeToArguments;
|
|
|
|
|
var thisValue = {
|
|
|
|
|
pipeTo: function() {
|
|
|
|
|
pipeToArguments = arguments;
|
|
|
|
|
}
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
var input = { readable: {}, writable: {} };
|
|
|
|
|
var options = {};
|
|
|
|
|
var result = ReadableStream.prototype.pipeThrough.call(thisValue, input, options);
|
|
|
|
|
|
|
|
|
|
assert_array_equals(pipeToArguments, [input.writable, options], 'correct arguments should be passed to thisValue.pipeTo');
|
|
|
|
|
assert_equals(result, input.readable, 'return value should be the passed readable property');
|
|
|
|
|
}, 'ReadableStream.prototype.pipeThrough works generically on its this and its arguments');
|
|
|
|
|
|
|
|
|
|
test(function() {
|
|
|
|
|
ReadableStream.prototype.pipeTo.call(fakeReadableStream(), fakeWritableStream()); // Check it does not throw.
|
|
|
|
|
}, 'ReadableStream.prototype.pipeTo works generically on its this and its arguments');
|
|
|
|
|
|
|
|
|
|
test(function() {
|
|
|
|
|
var thisValue = null;
|
|
|
|
|
var returnValue = { 'returned from': 'byteLength getter' };
|
|
|
|
|
var chunk = {
|
|
|
|
|
get byteLength() {
|
|
|
|
|
return returnValue;
|
|
|
|
|
}
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
assert_equals(ByteLengthQueuingStrategy.prototype.size.call(thisValue, chunk), returnValue);
|
|
|
|
|
}, 'ByteLengthQueuingStrategy.prototype.size should work generically on its this and its arguments');
|
|
|
|
|
|
|
|
|
|
test(function() {
|
|
|
|
|
var thisValue = null;
|
|
|
|
|
var chunk = {
|
|
|
|
|
get byteLength() {
|
|
|
|
|
throw new TypeError('shouldn\'t be called');
|
|
|
|
|
}
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
assert_equals(CountQueuingStrategy.prototype.size.call(thisValue, chunk), 1);
|
|
|
|
|
}, 'CountQueuingStrategy.prototype.size should work generically on its this and its arguments');
|
|
|
|
|
</script>
|
