Package io.servicetalk.concurrent.api

Class TestPublisher<T>

java.lang.Object

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

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

Type Parameters:

T - Type of the items emitted by this TestPublisher.

All Implemented Interfaces:

PublisherSource<T>

public final class TestPublisher<T>
extends Publisher<T>
implements PublisherSource<T>

A Publisher & PublisherSource whose outgoing signals to its PublisherSource.Subscribers can be controlled.

Behavior beyond simply delegating signals to the PublisherSource.Subscriber is accomplished by a Function<Subscriber<? super T>, Subscriber<? super T>>. This Function is invoked for every subscribe(Subscriber) invocation, and the result is used as the delegate for subsequent onSubscribe(Subscription), onNext(Object[]), onComplete(), and onError(Throwable) calls. See TestPublisher.Builder for more information.

Defaults

• Allows sequential but not concurrent subscribers.
• Asserts that onNext(Object[]) is not called without sufficient demand.
• Sends onSubscribe(Subscription) automatically when subscribed to.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestPublisher.Builder<T>	Allows for creating TestPublishers with non-default settings.

Nested classes/interfaces inherited from interface io.servicetalk.concurrent.PublisherSource

PublisherSource.Processor<T,R>, PublisherSource.Subscriber<T>, PublisherSource.Subscription

Constructor Summary

Constructors

Constructor	Description
TestPublisher()	Create a TestPublisher with the defaults.

Method Summary

Modifier and Type	Method	Description
protected void	handleSubscribe(PublisherSource.Subscriber<? super T> subscriber)	Handles a subscriber to this Publisher.
boolean	isSubscribed()	Returns true if this TestPublisher has been subscribed to, false otherwise.
void	onComplete()	Completes the PublisherSource.Subscriber.
void	onError(java.lang.Throwable t)	Delivers the Throwable t to the PublisherSource.Subscriber.
void	onNext(T... items)	Delivers the items, one at a time, to the PublisherSource.Subscriber.
void	onSubscribe(PublisherSource.Subscription subscription)	Delivers the PublisherSource.Subscription to the PublisherSource.Subscriber's PublisherSource.Subscriber.onSubscribe(Subscription).
void	subscribe(PublisherSource.Subscriber<? super T> subscriber)	Subscribe for the result(s) of this PublisherSource.

Methods inherited from class io.servicetalk.concurrent.api.Publisher

afterCancel, afterFinally, afterFinally, afterOnComplete, afterOnError, afterOnNext, afterOnSubscribe, afterRequest, afterSubscriber, afterSubscription, beforeCancel, beforeFinally, beforeFinally, beforeOnComplete, beforeOnError, beforeOnNext, beforeOnSubscribe, beforeRequest, beforeSubscriber, beforeSubscription, buffer, collect, completableOrError, concat, concat, concat, defer, empty, failed, filter, firstOrElse, firstOrError, flatMapCompletable, flatMapCompletable, flatMapCompletableDelayError, flatMapCompletableDelayError, flatMapCompletableDelayError, flatMapConcatIterable, flatMapMerge, flatMapMerge, flatMapMergeDelayError, flatMapMergeDelayError, flatMapMergeDelayError, flatMapMergeSingle, flatMapMergeSingle, flatMapMergeSingleDelayError, flatMapMergeSingleDelayError, flatMapMergeSingleDelayError, forEach, from, from, fromBlockingIterable, fromInputStream, fromIterable, groupBy, groupBy, groupToMany, groupToMany, idleTimeout, idleTimeout, idleTimeout, idleTimeout, ignoreElements, liftAsync, liftSync, liftSyncToSingle, map, multicastToExactly, multicastToExactly, never, publishAndSubscribeOn, publishAndSubscribeOnOverride, publishOn, publishOnOverride, range, range, recoverWith, repeat, repeatWhen, retry, retryWhen, subscribeInternal, subscribeOn, subscribeOnOverride, subscribeShareContext, takeAtMost, takeUntil, takeWhile, toCompletionStage, toCompletionStage, toFuture, toFuture, toInputStream, toInputStream, toIterable, toIterable, whenCancel, whenFinally, whenFinally, whenOnComplete, whenOnError, whenOnNext, whenOnSubscribe, whenRequest, whenSubscriber, whenSubscription

Methods inherited from class java.lang.Object

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

Constructor Detail

TestPublisher

public TestPublisher()

Create a TestPublisher with the defaults. See Defaults section of class javadoc.

Method Detail

isSubscribed

public boolean isSubscribed()

Returns true if this TestPublisher has been subscribed to, false otherwise.

Returns:

true if this TestPublisher has been subscribed to, false otherwise.

handleSubscribe

protected void handleSubscribe(PublisherSource.Subscriber<? super T> subscriber)

Description copied from class: Publisher

Handles a subscriber to this Publisher.

Specified by:

handleSubscribe in class Publisher<T>

Parameters:

subscriber - the subscriber.

subscribe

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

Description copied from interface: PublisherSource

Subscribe for the result(s) of this PublisherSource.

Specified by:

subscribe in interface PublisherSource<T>

Parameters:

subscriber - to subscribe for the result.

onSubscribe

public void onSubscribe(PublisherSource.Subscription subscription)

Delivers the PublisherSource.Subscription to the PublisherSource.Subscriber's PublisherSource.Subscriber.onSubscribe(Subscription).

In the case of auto-on-subscribe, the delegating PublisherSource.Subscription sent to the PublisherSource.Subscriber by the auto-on-subscribe will switch to subscription.

Parameters:

subscription - the PublisherSource.Subscription

onNext

@SafeVarargs
public final void onNext(@Nullable
                         T... items)

Delivers the items, one at a time, to the PublisherSource.Subscriber.

Parameters:

items - the items to deliver.

See Also:

PublisherSource.Subscriber.onNext(Object)

onComplete

public void onComplete()

Completes the PublisherSource.Subscriber.

See Also:

PublisherSource.Subscriber.onComplete()

onError

public void onError(java.lang.Throwable t)

Delivers the Throwable t to the PublisherSource.Subscriber.

Parameters:

t - the error to deliver.

See Also:

PublisherSource.Subscriber.onError(Throwable)