class MultiBroadcast {

    public Multi<T> toAllSubscribers() {
        return Infrastructure.onMultiCreation(
                MultiBroadcaster.publish(upstream, 0, cancelWhenNoOneIsListening, delayAfterLastDeparture));
    }

    public  MultiBroadcast(Multi<T> upstream);

}