Package io.servicetalk.concurrent.api
Class ConcurrentCompletableSubscriberFunction
- java.lang.Object
-
- io.servicetalk.concurrent.api.ConcurrentCompletableSubscriberFunction
-
- All Implemented Interfaces:
java.util.function.Function<CompletableSource.Subscriber,CompletableSource.Subscriber>
public final class ConcurrentCompletableSubscriberFunction extends java.lang.Object implements java.util.function.Function<CompletableSource.Subscriber,CompletableSource.Subscriber>
Allows multipleCompletableSource.Subscriber
s to be concurrently subscribed to aTestCompletable
, and multicasts signals to them all.
-
-
Constructor Summary
Constructors Constructor Description ConcurrentCompletableSubscriberFunction()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description CompletableSource.Subscriber
apply(CompletableSource.Subscriber subscriber)
java.util.List<CompletableSource.Subscriber>
subscribers()
Returns a list of allCompletableSource.Subscriber
s that have subscribed.
-
-
-
Method Detail
-
apply
public CompletableSource.Subscriber apply(CompletableSource.Subscriber subscriber)
- Specified by:
apply
in interfacejava.util.function.Function<CompletableSource.Subscriber,CompletableSource.Subscriber>
-
subscribers
public java.util.List<CompletableSource.Subscriber> subscribers()
Returns a list of allCompletableSource.Subscriber
s that have subscribed.- Returns:
- a list of all
CompletableSource.Subscriber
s that have subscribed.
-
-