io.servicetalk.concurrent.api

Class ConcurrentPublisherSubscriberFunction<T>

java.lang.Object

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

Allows multiple PublisherSource.Subscribers to be concurrently subscribed to a TestPublisher, and multicasts signals to them all.

Constructor Summary

Constructors

Constructor and Description
ConcurrentPublisherSubscriberFunction()

Method Summary

Modifier and Type	Method and Description
PublisherSource.Subscriber<? super T>	apply(PublisherSource.Subscriber<? super T> subscriber)
java.util.List<PublisherSource.Subscriber<? super T>>	subscribers() Returns a list of all PublisherSource.Subscribers that have subscribed.

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

ConcurrentPublisherSubscriberFunction

public ConcurrentPublisherSubscriberFunction()

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

subscribers

public java.util.List<PublisherSource.Subscriber<? super T>> subscribers()

Returns a list of all PublisherSource.Subscribers that have subscribed.

Returns:

a list of all PublisherSource.Subscribers that have subscribed.