Package io.servicetalk.concurrent.api

Class TestSingle.Builder<T>

java.lang.Object

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

Type Parameters:

T - Type of the result of the TestSingle.

Enclosing class:

TestSingle<T>

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

Allows for creating TestSingles 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
TestSingle.Builder<T>	autoOnSubscribe()	Enable calling SingleSource.Subscriber.onSubscribe(Cancellable) automatically upon subscribe.
TestSingle.Builder<T>	autoOnSubscribe(AutoOnSubscribeSingleSubscriberFunction<T> function)	Enable calling SingleSource.Subscriber.onSubscribe(Cancellable) automatically upon subscribe, with the specified AutoOnSubscribeSingleSubscriberFunction.
TestSingle<T>	build()	Create a TestSingle as configured by the builder.
TestSingle<T>	build(java.util.function.Function<SingleSource.Subscriber<? super T>,SingleSource.Subscriber<? super T>> function)	Create a TestSingle using the specified subscriber function.
TestSingle.Builder<T>	concurrentSubscribers()	Allow concurrent subscribers.
TestSingle.Builder<T>	concurrentSubscribers(ConcurrentSingleSubscriberFunction<T> function)	Allow concurrent subscribers, with the specified ConcurrentSingleSubscriberFunction.
TestSingle.Builder<T>	disableAutoOnSubscribe()	Disable calling SingleSource.Subscriber.onSubscribe(Cancellable) automatically upon subscribe.
TestSingle.Builder<T>	sequentialSubscribers()	Allow sequential subscribers.
TestSingle.Builder<T>	sequentialSubscribers(SequentialSingleSubscriberFunction<T> function)	Allow sequential subscribers, with the specified SequentialSingleSubscriberFunction.
TestSingle.Builder<T>	singleSubscriber()	Allow only a single subscriber.
TestSingle.Builder<T>	singleSubscriber(NonResubscribeableSingleSubscriberFunction<T> function)	Allow only a single subscriber, with the specified NonResubscribeableSingleSubscriberFunction.

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 TestSingle.Builder<T> concurrentSubscribers()

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

Returns:

this.

See Also:

ConcurrentSingleSubscriberFunction

concurrentSubscribers

public TestSingle.Builder<T> concurrentSubscribers(ConcurrentSingleSubscriberFunction<T> function)

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

Parameters:

function - the ConcurrentSingleSubscriberFunction to use.

Returns:

this.

sequentialSubscribers

public TestSingle.Builder<T> sequentialSubscribers()

Allow sequential subscribers. This is the default.

Returns:

this.

See Also:

SequentialSingleSubscriberFunction

sequentialSubscribers

public TestSingle.Builder<T> sequentialSubscribers(SequentialSingleSubscriberFunction<T> function)

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

Parameters:

function - the SequentialSingleSubscriberFunction to use.

Returns:

this.

singleSubscriber

public TestSingle.Builder<T> singleSubscriber()

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

Returns:

this.

See Also:

NonResubscribeableSingleSubscriberFunction

singleSubscriber

public TestSingle.Builder<T> singleSubscriber(NonResubscribeableSingleSubscriberFunction<T> function)

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

Parameters:

function - the NonResubscribeableSingleSubscriberFunction to use.

Returns:

this.

autoOnSubscribe

public TestSingle.Builder<T> autoOnSubscribe()

Enable calling SingleSource.Subscriber.onSubscribe(Cancellable) automatically upon subscribe. The default is enabled.

Returns:

this.

See Also:

AutoOnSubscribeSingleSubscriberFunction

autoOnSubscribe

public TestSingle.Builder<T> autoOnSubscribe(AutoOnSubscribeSingleSubscriberFunction<T> function)

Enable calling SingleSource.Subscriber.onSubscribe(Cancellable) automatically upon subscribe, with the specified AutoOnSubscribeSingleSubscriberFunction. The default is enabled.

Parameters:

function - the AutoOnSubscribeSingleSubscriberFunction to use.

Returns:

this.

disableAutoOnSubscribe

public TestSingle.Builder<T> disableAutoOnSubscribe()

Disable calling SingleSource.Subscriber.onSubscribe(Cancellable) automatically upon subscribe. The default is enabled.

Returns:

this.

build

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

Create a TestSingle using the specified subscriber function.

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

Parameters:

function - The subscriber function to use.

Returns:

a new TestSingle.

build

public TestSingle<T> build()

Create a TestSingle as configured by the builder.

Returns:

a new TestSingle.