class MultiBroadcast {

    public Multi<T> toAtLeast(int numberOfSubscribers) {
        positive(numberOfSubscribers, "numberOfSubscribers");
        return Infrastructure.onMultiCreation(
                MultiBroadcaster.publish(upstream, numberOfSubscribers, cancelWhenNoOneIsListening, delayAfterLastDeparture));
    }

    public  MultiBroadcast(Multi<T> upstream);

}