class PublisherProcessor extends Publisher<T> implements Processor<T, T>, Subscription {

    @Override
    public void subscribe(final Subscriber<? super T> subscriber) {
        subscribeInternal(subscriber);
    }

      PublisherProcessor(final PublisherProcessorSignalsHolder<T> buffer);

}