ble(head) || isWritableStream(head) || isTransformStream(head)), readable = !!(isReadable(tail) || isReadableStream(tail) || isTransformStream(tail));
  if (d = new Duplex({
    writableObjectMode: !!head?.writableObjectMode,
    readableObjectMode: !!tail?.readableObjectMode,
    writable,
    readable
  }), writable) {
    if (isNodeStream(head))
      d._write = function(chunk, encoding, callback) {
        if (head.write(chunk, encoding))
          callback();
        else
          ondrain = callback;
      }, d._final = function(callback) {
        head.end(), onfinish = callback;
      }, head.on("drain", function() {
        if (ondrain) {
          let cb = ondrain;
          ondrain = null, cb();
        }
      });
    else if (isWebStream(head)) {
      let writer = (isTransformStream(head) ? head.writable : head).getWriter();
      d._write = async function(chunk, encoding, callback) {
        try {
          await writer.ready, writer.write(chunk).catch(() => {}), callback();
        } catch (err) {
          callback(err);
        }
      }, d._final = async function(callback) {
        try {
          await writer.ready, writer.close().catch(() => {}), onfinish = callback;
        } catch (err) {
          callback(err);
        }
      };
    }
    let toRead = isTransformStream(tail) ? tail.readable : tail;
    eos(toRead, () => {
      if (onfinish) {
        let cb = onfinish;
        onfinish = null, cb();
      }
    });
  }
  if (readable) {
    if (isNodeStream(tail))
      tail.on("readable", function() {
        if (onreadable) {
          let cb = onreadable;
          onreadable = null, cb();
        }
      }), tail.on("end", function() {
        d.push(null);
      }), d._read = function() {
        while (!0) {
          let buf = tail.read();
          if (buf === null) {
            onreadable = d._read;
            return;
          }
          if (!d.push(buf))
            return;
        }
      };
    else if (isWebStream(tail)) {
      let reader = (isTransformStream(tail) ? tail.readable : tail).getReader();
      d._read = async function() {
        while (!0)
          try {
            let { value, done } = await reader.read();
            if (!d.push(value))
              return;
            if (done) {
              d.push(null);
              return;
            }
          } catch {
            return;
          }
      };
    }
  }
  return d._destroy = function(err, callback) {
    if (!err && onclose !== null)
      err = @makeAbortError();
    if (onreadable = null, ondrain = null, onfinish = null, isNodeStream(tail))
      destroyer(tail, err);
    if (onclose === null)
      callback(err);
    else
      onclose = callback;
  }, d;
};
return $})