io.servicetalk.concurrent.api

Class AutoOnSubscribePublisherSubscriberFunction<T>

java.lang.Object

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

Type Parameters:

T - Type of items received by the Subscriber.

All Implemented Interfaces:

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

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

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

Constructor Summary

Constructors

Constructor and Description
AutoOnSubscribePublisherSubscriberFunction()

Method Summary

Modifier and Type	Method and Description
PublisherSource.Subscriber<? super T>	apply(PublisherSource.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

AutoOnSubscribePublisherSubscriberFunction

public AutoOnSubscribePublisherSubscriberFunction()

Method Detail

apply

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

Specified by:

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