TransformStreamDefaultController-impl.js

'use strict';

const aos = require('./abstract-ops/transform-streams.js');
const rsAOs = require('./abstract-ops/readable-streams.js');

exports.implementation = class TransformStreamDefaultController {
  get desiredSize() {
    const readableController = this._stream._readable._controller;
    return rsAOs.ReadableStreamDefaultControllerGetDesiredSize(readableController);
  }

  enqueue(chunk, options) {
    const transferList = options ? options.transfer : undefined;
    aos.TransformStreamDefaultControllerEnqueue(this, chunk, transferList);
  }

  error(reason) {
    aos.TransformStreamDefaultControllerError(this, reason);
  }

  terminate() {
    aos.TransformStreamDefaultControllerTerminate(this);
  }
};