text: /* */ 
  "format cjs";
    /**
     * Pipes the existing Observable sequence into a Node.js Stream.
     * @param {Stream} dest The destination Node.js stream.
     * @returns {Stream} The destination stream.
     */
    observableProto.pipe = function (dest) {
      var source = this.pausableBuffered();
  
      function onDrain() {
        source.resume();
      }
  
      dest.addListener('drain', onDrain);
  
      source.subscribe(
        function (x) {
          !dest.write(String(x)) && source.pause();
        },
        function (err) {
          dest.emit('error', err);
        },
        function () {
          // Hack check because STDIO is not closable
          !dest._isStdio && dest.end();
          dest.removeListener('drain', onDrain);
        });
  
      source.resume();
  
      return dest;
    };
  