TextEncoderStream.js [plain text]
function initializeTextEncoderStream()
{
"use strict";
const startAlgorithm = () => {
return @Promise.@resolve();
};
const transformAlgorithm = (chunk) => {
const encoder = @getByIdDirectPrivate(this, "textEncoderStreamEncoder");
let buffer;
try {
buffer = encoder.@encode(chunk);
} catch (e) {
return @Promise.@reject(e);
}
if (buffer) {
const transformStream = @getByIdDirectPrivate(this, "textEncoderStreamTransform");
const controller = @getByIdDirectPrivate(transformStream, "controller");
@transformStreamDefaultControllerEnqueue(controller, buffer);
}
return @Promise.@resolve();
};
const flushAlgorithm = () => {
const encoder = @getByIdDirectPrivate(this, "textEncoderStreamEncoder");
const buffer = encoder.@flush();
if (buffer) {
const transformStream = @getByIdDirectPrivate(this, "textEncoderStreamTransform");
const controller = @getByIdDirectPrivate(transformStream, "controller");
@transformStreamDefaultControllerEnqueue(controller, buffer);
}
return @Promise.@resolve();
};
const transform = @createTransformStream(startAlgorithm, transformAlgorithm, flushAlgorithm);
@putByIdDirectPrivate(this, "textEncoderStreamTransform", transform);
@putByIdDirectPrivate(this, "textEncoderStreamEncoder", new @TextEncoderStreamEncoder());
return this;
}
@getter
function encoding()
{
"use strict";
if (!@getByIdDirectPrivate(this, "textEncoderStreamTransform"))
throw @makeThisTypeError("TextEncoderStream", "encoding");
return "utf-8";
}
@getter
function readable()
{
"use strict";
const transform = @getByIdDirectPrivate(this, "textEncoderStreamTransform");
if (!transform)
throw @makeThisTypeError("TextEncoderStream", "readable");
return @getByIdDirectPrivate(transform, "readable");
}
@getter
function writable()
{
"use strict";
const transform = @getByIdDirectPrivate(this, "textEncoderStreamTransform");
if (!transform)
throw @makeThisTypeError("TextEncoderStream", "writable");
return @getByIdDirectPrivate(transform, "writable");
}