public final class NonResubscribeableCompletableSubscriberFunction extends java.lang.Object implements java.util.function.Function<CompletableSource.Subscriber,CompletableSource.Subscriber>
CompletableSource.Subscriber
to subscribe to a TestCompletable
. Subsequent attempts to subscribe
will throw an exception.Constructor and Description |
---|
NonResubscribeableCompletableSubscriberFunction() |
Modifier and Type | Method and Description |
---|---|
CompletableSource.Subscriber |
apply(CompletableSource.Subscriber subscriber) |
public NonResubscribeableCompletableSubscriberFunction()
public CompletableSource.Subscriber apply(CompletableSource.Subscriber subscriber)
apply
in interface java.util.function.Function<CompletableSource.Subscriber,CompletableSource.Subscriber>