public final class ConcurrentCompletableSubscriberFunction extends java.lang.Object implements java.util.function.Function<CompletableSource.Subscriber,CompletableSource.Subscriber>
CompletableSource.Subscriber
s to be concurrently subscribed to a TestCompletable
, and multicasts
signals to them all.Constructor and Description |
---|
ConcurrentCompletableSubscriberFunction() |
Modifier and Type | Method and Description |
---|---|
CompletableSource.Subscriber |
apply(CompletableSource.Subscriber subscriber) |
java.util.List<CompletableSource.Subscriber> |
subscribers()
Returns a list of all
CompletableSource.Subscriber s that have subscribed. |
public ConcurrentCompletableSubscriberFunction()
public CompletableSource.Subscriber apply(CompletableSource.Subscriber subscriber)
apply
in interface java.util.function.Function<CompletableSource.Subscriber,CompletableSource.Subscriber>
public java.util.List<CompletableSource.Subscriber> subscribers()
CompletableSource.Subscriber
s that have subscribed.CompletableSource.Subscriber
s that have subscribed.