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