@Test public void testSubscriptionAfterUpstreamCompletion() { MultiEmitterProcessor<Integer> processor = MultiEmitterProcessor.create(); processor.emit(1).emit(2).emit(3); processor.complete(); processor.toMulti().broadcast().toAllSubscribers().subscribe().withSubscriber(AssertSubscriber.create(10)) .assertReceived(1, 2, 3) .assertCompletedSuccessfully(); }
public Multi<T> toAllSubscribers() { return Infrastructure.onMultiCreation( MultiBroadcaster.publish(upstream, 0, cancelWhenNoOneIsListening, delayAfterLastDeparture)); }
MultiBroadcast { public Multi<T> toAllSubscribers() { return Infrastructure.onMultiCreation( MultiBroadcaster.publish(upstream, 0, cancelWhenNoOneIsListening, delayAfterLastDeparture)); } }
MultiBroadcast { public Multi<T> toAllSubscribers() { return Infrastructure.onMultiCreation( MultiBroadcaster.publish(upstream, 0, cancelWhenNoOneIsListening, delayAfterLastDeparture)); } MultiBroadcast(Multi<T> upstream); }
MultiBroadcast { public Multi<T> toAllSubscribers() { return Infrastructure.onMultiCreation( MultiBroadcaster.publish(upstream, 0, cancelWhenNoOneIsListening, delayAfterLastDeparture)); } MultiBroadcast(Multi<T> upstream); Multi<T> toAllSubscribers(); Multi<T> toAtLeast(int numberOfSubscribers); MultiBroadcast<T> withCancellationAfterLastSubscriberDeparture(); MultiBroadcast<T> withCancellationAfterLastSubscriberDeparture(Duration delay); }
MultiBroadcast { public Multi<T> toAllSubscribers() { return Infrastructure.onMultiCreation( MultiBroadcaster.publish(upstream, 0, cancelWhenNoOneIsListening, delayAfterLastDeparture)); } MultiBroadcast(Multi<T> upstream); Multi<T> toAllSubscribers(); Multi<T> toAtLeast(int numberOfSubscribers); MultiBroadcast<T> withCancellationAfterLastSubscriberDeparture(); MultiBroadcast<T> withCancellationAfterLastSubscriberDeparture(Duration delay);  }