public ReplayProcessor(int bufferSize,boolean unbounded){
  if (unbounded) {
    this.buffer=new UnboundedBuffer<>(bufferSize);
  }
 else {
    this.buffer=new BoundedBuffer<>(bufferSize);
  }
  SUBSCRIBERS.lazySet(this,EMPTY);
}

public ReplayProcessor ( int bufferSize , boolean unbounded ) { if ( unbounded ) { this . buffer = new UnboundedBuffer < > ( bufferSize ) ; } else { this . buffer = new BoundedBuffer < > ( bufferSize ) ; } SUBSCRIBERS . lazySet ( this , EMPTY ) ; }
constructs a replayprocessor with bounded or unbounded buffering .
