io.servicetalk.concurrent.api

Class AutoOnSubscribeSingleSubscriberFunction<T>

java.lang.Object

io.servicetalk.concurrent.api.AutoOnSubscribeSingleSubscriberFunction<T>

Type Parameters:

T - Type of the result of the Subscriber.

All Implemented Interfaces:

java.util.function.Function<SingleSource.Subscriber<? super T>,SingleSource.Subscriber<? super T>>

public final class AutoOnSubscribeSingleSubscriberFunction<T>
extends java.lang.Object
implements java.util.function.Function<SingleSource.Subscriber<? super T>,SingleSource.Subscriber<? super T>>

Calls SingleSource.Subscriber.onSubscribe(Cancellable) automatically, sending a delegating Cancellable. Returns a SingleSource.Subscriber which, upon receiving SingleSource.Subscriber.onSubscribe(Cancellable), uses the received Cancellable to delegate to.

Constructor Summary

Constructors

Constructor and Description
AutoOnSubscribeSingleSubscriberFunction()

Method Summary

Modifier and Type	Method and Description
SingleSource.Subscriber<? super T>	apply(SingleSource.Subscriber<? super T> subscriber)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.function.Function

andThen, compose, identity

Constructor Detail

AutoOnSubscribeSingleSubscriberFunction

public AutoOnSubscribeSingleSubscriberFunction()

Method Detail

apply

public SingleSource.Subscriber<? super T> apply(SingleSource.Subscriber<? super T> subscriber)

Specified by:

apply in interface java.util.function.Function<SingleSource.Subscriber<? super T>,SingleSource.Subscriber<? super T>>