function fillFetchHeaders(headers, headersInit)
{
"use strict";
if (headersInit === @undefined)
return;
if (headersInit instanceof @Headers) {
@Headers.prototype.@fillFromJS.@call(headers, headersInit);
return;
}
if (@isArray(headersInit)) {
for (let i = 0; i < headersInit.length; i++) {
let header = headersInit[i];
if (header.length !== 2)
@throwTypeError("headersInit sequence items should contain two values");
@Headers.prototype.@appendFromJS.@call(headers, header[0], header[1]);
}
return this;
}
let propertyNames = @Object.@getOwnPropertyNames(headersInit);
for (let i = 0; i < propertyNames.length; ++i) {
let name = propertyNames[i];
@Headers.prototype.@appendFromJS.@call(headers, name, headersInit[name]);
}
}
function consumeStream(response, type)
{
@assert(response instanceof @Response);
@assert(response.@body instanceof @ReadableStream);
if (@isReadableStreamDisturbed(response.@body))
return @Promise.@reject(new @TypeError("Cannot consume a disturbed Response body ReadableStream"));
try {
let reader = new @ReadableStreamDefaultReader(response.@body);
@Response.prototype.@startConsumingStream.@call(response, type);
let pull = (result) => {
if (result.done)
return @Response.prototype.@finishConsumingStream.@call(response);
@Response.prototype.@consumeChunk.@call(response, result.value);
return @Promise.prototype.@then.@call(@readableStreamDefaultReaderRead(reader), pull);
}
return @Promise.prototype.@then.@call(@readableStreamDefaultReaderRead(reader), pull);
} catch (e) {
return @Promise.@reject(e);
}
}