io.servicetalk.concurrent.api

Class DemandCheckingSubscriberFunction<T>

java.lang.Object

io.servicetalk.concurrent.api.DemandCheckingSubscriberFunction<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 DemandCheckingSubscriberFunction<T>
extends java.lang.Object
implements java.util.function.Function<PublisherSource.Subscriber<? super T>,PublisherSource.Subscriber<? super T>>

Wraps PublisherSource.Subscribers in a DemandCheckingSubscriber.

Constructor Summary

Constructors

Constructor and Description
DemandCheckingSubscriberFunction()

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

DemandCheckingSubscriberFunction

public DemandCheckingSubscriberFunction()

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>>