ReadableStreamDefaultReader.js [plain text]
function cancel(reason)
{
"use strict";
if (!@isReadableStreamDefaultReader(this))
return @Promise.@reject(@makeThisTypeError("ReadableStreamDefaultReader", "cancel"));
if (!this.@ownerReadableStream)
return @Promise.@reject(new @TypeError("cancel() called on a reader owned by no readable stream"));
return @readableStreamReaderGenericCancel(this, reason);
}
function read()
{
"use strict";
if (!@isReadableStreamDefaultReader(this))
return @Promise.@reject(@makeThisTypeError("ReadableStreamDefaultReader", "read"));
if (!this.@ownerReadableStream)
return @Promise.@reject(new @TypeError("read() called on a reader owned by no readable stream"));
return @readableStreamDefaultReaderRead(this);
}
function releaseLock()
{
"use strict";
if (!@isReadableStreamDefaultReader(this))
throw @makeThisTypeError("ReadableStreamDefaultReader", "releaseLock");
if (!this.@ownerReadableStream)
return;
if (this.@readRequests.length)
@throwTypeError("There are still pending read requests, cannot release the lock");
@readableStreamReaderGenericRelease(this);
}
function closed()
{
"use strict";
if (!@isReadableStreamDefaultReader(this))
return @Promise.@reject(@makeGetterTypeError("ReadableStreamDefaultReader", "closed"));
return this.@closedPromiseCapability.@promise;
}