Package io.servicetalk.concurrent.api

Class TestCompletable.Builder

java.lang.Object

io.servicetalk.concurrent.api.TestCompletable.Builder

Enclosing class:

TestCompletable

public static class TestCompletable.Builder
extends java.lang.Object

Allows for creating TestCompletables 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
TestCompletable.Builder	autoOnSubscribe()	Enable calling CompletableSource.Subscriber.onSubscribe(Cancellable) automatically upon subscribe.
TestCompletable.Builder	autoOnSubscribe(AutoOnSubscribeCompletableSubscriberFunction function)	Enable calling CompletableSource.Subscriber.onSubscribe(Cancellable) automatically upon subscribe, with the specified AutoOnSubscribeCompletableSubscriberFunction.
TestCompletable	build()	Create a TestCompletable as configured by the builder.
TestCompletable	build(java.util.function.Function<CompletableSource.Subscriber,CompletableSource.Subscriber> function)	Create a TestCompletable using the specified subscriber function.
TestCompletable.Builder	concurrentSubscribers()	Allow concurrent subscribers.
TestCompletable.Builder	concurrentSubscribers(ConcurrentCompletableSubscriberFunction function)	Allow concurrent subscribers, with the specified ConcurrentCompletableSubscriberFunction.
TestCompletable.Builder	disableAutoOnSubscribe()	Disable calling CompletableSource.Subscriber.onSubscribe(Cancellable) automatically upon subscribe.
TestCompletable.Builder	sequentialSubscribers()	Allow sequential subscribers.
TestCompletable.Builder	sequentialSubscribers(SequentialCompletableSubscriberFunction function)	Allow sequential subscribers, with the specified SequentialCompletableSubscriberFunction.
TestCompletable.Builder	singleSubscriber()	Allow only a single subscriber.
TestCompletable.Builder	singleSubscriber(NonResubscribeableCompletableSubscriberFunction function)	Allow only a single subscriber, with the specified NonResubscribeableCompletableSubscriberFunction.

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

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

Returns:

this.

See Also:

ConcurrentCompletableSubscriberFunction

concurrentSubscribers

public TestCompletable.Builder concurrentSubscribers(ConcurrentCompletableSubscriberFunction function)

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

Parameters:

function - the ConcurrentCompletableSubscriberFunction to use.

Returns:

this.

sequentialSubscribers

public TestCompletable.Builder sequentialSubscribers()

Allow sequential subscribers. This is the default.

Returns:

this.

See Also:

SequentialCompletableSubscriberFunction

sequentialSubscribers

public TestCompletable.Builder sequentialSubscribers(SequentialCompletableSubscriberFunction function)

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

Parameters:

function - the SequentialCompletableSubscriberFunction to use.

Returns:

this.

singleSubscriber

public TestCompletable.Builder singleSubscriber()

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

Returns:

this.

See Also:

NonResubscribeableCompletableSubscriberFunction

singleSubscriber

public TestCompletable.Builder singleSubscriber(NonResubscribeableCompletableSubscriberFunction function)

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

Parameters:

function - the NonResubscribeableCompletableSubscriberFunction to use.

Returns:

this.

autoOnSubscribe

public TestCompletable.Builder autoOnSubscribe()

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

Returns:

this.

See Also:

AutoOnSubscribeCompletableSubscriberFunction

autoOnSubscribe

public TestCompletable.Builder autoOnSubscribe(AutoOnSubscribeCompletableSubscriberFunction function)

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

Parameters:

function - the AutoOnSubscribeCompletableSubscriberFunction to use.

Returns:

this.

disableAutoOnSubscribe

public TestCompletable.Builder disableAutoOnSubscribe()

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

Returns:

this.

build

public TestCompletable build(java.util.function.Function<CompletableSource.Subscriber,CompletableSource.Subscriber> function)

Create a TestCompletable using the specified subscriber function.

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

Parameters:

function - The subscriber function to use.

Returns:

a new TestCompletable.

build

public TestCompletable build()

Create a TestCompletable as configured by the builder.

Returns:

a new TestCompletable.