io.servicetalk.concurrent.api

Class NonResubscribeablePublisherSubscriberFunction<T>

java.lang.Object

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

Allows only a single PublisherSource.Subscriber to subscribe to a TestPublisher. Subsequent attempts to subscribe will throw an exception.

Constructor Summary

Constructors

Constructor and Description
NonResubscribeablePublisherSubscriberFunction()

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

NonResubscribeablePublisherSubscriberFunction

public NonResubscribeablePublisherSubscriberFunction()

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