class MulticastPublisher extends AbstractNoHandleSubscribePublisher<T> implements Subscriber<T> {

    @Override
    public void onSubscribe(Subscription s) {
        delayedSubscription.delayedSubscription(s);
    }

      MulticastPublisher(Publisher<T> original, int expectedSubscribers, Executor executor);
      MulticastPublisher(Publisher<T> original, int expectedSubscribers, int maxQueueSize, Executor executor);

}