code: function Stream(trackSubscribers, buffer) {
    if (!(this instanceof Stream)) {
      return new Stream(trackSubscribers, buffer);
    }
  
    this.trackSubscribers = !!trackSubscribers;
    this.subscribers = null;
    this.subscriberSubscribers = null;
    this.streamID = nextID++;
    this.values = Util.isDefined(buffer) ? buffer : Buffer.create(1, 'sliding');
    this.closed = false;
    this.closeSubscribers = null;
    this.emptySubscribers = null;
  
    openStreams[this.streamID] = this;
  }
docs: Ghetto Record implementation.