class BlockingQueueStreamSource implements StreamSource<T> {

  public void error( Throwable throwable ) {
    publishProcessor.onError( throwable );
  }

  protected  BlockingQueueStreamSource( BaseStreamStep streamStep );

}