Package io.servicetalk.concurrent.api

Class TestPublisher.Builder<T>

java.lang.Object

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

Type Parameters:

T - Type of the items emitted by the TestPublisher.

Enclosing class:

TestPublisher<T>

public static class TestPublisher.Builder<T>
extends java.lang.Object

Allows for creating TestPublishers with non-default settings. For defaults, see Defaults section of class javadoc.

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
TestPublisher.Builder<T>	autoOnSubscribe()	Enable calling PublisherSource.Subscriber.onSubscribe(Subscription) automatically upon subscribe.
TestPublisher.Builder<T>	autoOnSubscribe(AutoOnSubscribePublisherSubscriberFunction<T> function)	Enable calling PublisherSource.Subscriber.onSubscribe(Subscription) automatically upon subscribe, with the specified AutoOnSubscribePublisherSubscriberFunction.
TestPublisher<T>	build()	Create a TestPublisher as configured by the builder.
TestPublisher<T>	build(java.util.function.Function<PublisherSource.Subscriber<? super T>,PublisherSource.Subscriber<? super T>> function)	Create a TestPublisher using the specified subscriber function.
TestPublisher.Builder<T>	concurrentSubscribers()	Allow concurrent subscribers.
TestPublisher.Builder<T>	concurrentSubscribers(ConcurrentPublisherSubscriberFunction<T> function)	Allow concurrent subscribers, with the specified ConcurrentPublisherSubscriberFunction.
TestPublisher.Builder<T>	disableAutoOnSubscribe()	Disable calling PublisherSource.Subscriber.onSubscribe(Subscription) automatically upon subscribe.
TestPublisher.Builder<T>	disableDemandCheck()	Disables asserting items are not delivered without sufficient demand.
TestPublisher.Builder<T>	enableDemandCheck()	Enables asserting items are not delivered without sufficient demand.
TestPublisher.Builder<T>	enableDemandCheck(DemandCheckingSubscriberFunction<T> function)	Enables asserting items are not delivered without sufficient demand, with the specified DemandCheckingSubscriberFunction.
TestPublisher.Builder<T>	sequentialSubscribers()	Allow sequential subscribers.
TestPublisher.Builder<T>	sequentialSubscribers(SequentialPublisherSubscriberFunction<T> function)	Allow sequential subscribers, with the specified SequentialPublisherSubscriberFunction.
TestPublisher.Builder<T>	singleSubscriber()	Allow only a single subscriber.
TestPublisher.Builder<T>	singleSubscriber(NonResubscribeablePublisherSubscriberFunction<T> function)	Allow only a single subscriber, with the specified NonResubscribeablePublisherSubscriberFunction.

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder()

Method Detail

concurrentSubscribers

public TestPublisher.Builder<T> concurrentSubscribers()

Allow concurrent subscribers. Default is to allow only sequential subscribers.

Returns:

this.

See Also:

ConcurrentPublisherSubscriberFunction

concurrentSubscribers

public TestPublisher.Builder<T> concurrentSubscribers(ConcurrentPublisherSubscriberFunction<T> function)

Allow concurrent subscribers, with the specified ConcurrentPublisherSubscriberFunction. Default is to allow only sequential subscribers.

Parameters:

function - the ConcurrentPublisherSubscriberFunction to use.

Returns:

this.

sequentialSubscribers

public TestPublisher.Builder<T> sequentialSubscribers()

Allow sequential subscribers. This is the default.

Returns:

this.

See Also:

SequentialPublisherSubscriberFunction

sequentialSubscribers

public TestPublisher.Builder<T> sequentialSubscribers(SequentialPublisherSubscriberFunction<T> function)

Allow sequential subscribers, with the specified SequentialPublisherSubscriberFunction. This is the default.

Parameters:

function - the SequentialPublisherSubscriberFunction to use.

Returns:

this.

singleSubscriber

public TestPublisher.Builder<T> singleSubscriber()

Allow only a single subscriber. Default is to allow sequential subscribers.

Returns:

this.

See Also:

NonResubscribeablePublisherSubscriberFunction

singleSubscriber

public TestPublisher.Builder<T> singleSubscriber(NonResubscribeablePublisherSubscriberFunction<T> function)

Allow only a single subscriber, with the specified NonResubscribeablePublisherSubscriberFunction. Default is to allow sequential subscribers.

Parameters:

function - the NonResubscribeablePublisherSubscriberFunction to use.

Returns:

this.

enableDemandCheck

public TestPublisher.Builder<T> enableDemandCheck()

Enables asserting items are not delivered without sufficient demand. The default is enabled.

Returns:

this.

See Also:

DemandCheckingSubscriber

enableDemandCheck

public TestPublisher.Builder<T> enableDemandCheck(DemandCheckingSubscriberFunction<T> function)

Enables asserting items are not delivered without sufficient demand, with the specified DemandCheckingSubscriberFunction. The default is enabled.

Parameters:

function - the DemandCheckingSubscriberFunction to use.

Returns:

this.

disableDemandCheck

public TestPublisher.Builder<T> disableDemandCheck()

Disables asserting items are not delivered without sufficient demand. The default is enabled.

Returns:

this.

autoOnSubscribe

public TestPublisher.Builder<T> autoOnSubscribe()

Enable calling PublisherSource.Subscriber.onSubscribe(Subscription) automatically upon subscribe. The default is enabled.

Returns:

this.

See Also:

AutoOnSubscribePublisherSubscriberFunction

autoOnSubscribe

public TestPublisher.Builder<T> autoOnSubscribe(AutoOnSubscribePublisherSubscriberFunction<T> function)

Enable calling PublisherSource.Subscriber.onSubscribe(Subscription) automatically upon subscribe, with the specified AutoOnSubscribePublisherSubscriberFunction. The default is enabled.

Parameters:

function - the AutoOnSubscribePublisherSubscriberFunction to use.

Returns:

this.

disableAutoOnSubscribe

public TestPublisher.Builder<T> disableAutoOnSubscribe()

Disable calling PublisherSource.Subscriber.onSubscribe(Subscription) automatically upon subscribe. The default is enabled.

Returns:

this.

build

public TestPublisher<T> build(java.util.function.Function<PublisherSource.Subscriber<? super T>,PublisherSource.Subscriber<? super T>> function)

Create a TestPublisher using the specified subscriber function.

All other settings from this TestPublisher.Builder will be ignored.

Parameters:

function - The subscriber function to use.

Returns:

a new TestPublisher.

build

public TestPublisher<T> build()

Create a TestPublisher as configured by the builder.

Returns:

a new TestPublisher.