public void quit(){
  queue.add(STOP_MARKER);
  subject.onCompleted();
  subscription.unsubscribe();
}

public void quit ( ) { queue . add ( STOP_MARKER ) ; subject . onCompleted ( ) ; subscription . unsubscribe ( ) ; }
terminates the work of this backlog instance
