Function ServerStream

lib/stream-socket.js:33–48

(socket)

function ServerStream(socket) {
  Duplex.call(this, {objectMode: true});

  this.socket = socket;

  this.on('error', function(error) {
    logger.warn('ShareDB client message stream error', error);
    socket.close('stopped');
  });

  // The server ended the writable stream. Triggered by calling stream.end()
  // in agent.close()
  this.on('finish', function() {
    socket.close('stopped');
  });
}
util.inherits(ServerStream, Duplex);

ServerStream.prototype.isServer = true;