io.servicetalk.concurrent.api

Class TestPublisherSubscriber.Builder<T>

java.lang.Object

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

Type Parameters:

T - Type of items received by the TestPublisherSubscriber.

Enclosing class:

TestPublisherSubscriber<T>

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

Allows for creating TestPublisherSubscribers with non-default settings.

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
TestPublisherSubscriber<T>	build() Create a TestPublisherSubscriber as configured by the builder.
TestPublisherSubscriber.Builder<T>	disableDemandCheck() Disables asserting items are not delivered without sufficient demand.
TestPublisherSubscriber.Builder<T>	disableLogging() Disables logging signals.
TestPublisherSubscriber.Builder<T>	enableDemandCheck() Enables asserting items are not delivered without sufficient demand.
TestPublisherSubscriber.Builder<T>	enableLogging() Enables logging signals, with the default logger name.
TestPublisherSubscriber.Builder<T>	enableLogging(java.lang.String loggingName) Enables logging signals, with the specified logger name.
TestPublisherSubscriber.Builder<T>	lastSubscriber(PublisherSource.Subscriber<T> subscriber) Invoke PublisherSource.Subscriber after all other validation and collection is done.

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

lastSubscriber

public TestPublisherSubscriber.Builder<T> lastSubscriber(PublisherSource.Subscriber<T> subscriber)

Invoke PublisherSource.Subscriber after all other validation and collection is done.

Parameters:

subscriber - the PublisherSource.Subscriber to invoke.

Returns:

this.

enableDemandCheck

public TestPublisherSubscriber.Builder<T> enableDemandCheck()

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

Returns:

this.

disableDemandCheck

public TestPublisherSubscriber.Builder<T> disableDemandCheck()

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

Returns:

this.

enableLogging

public TestPublisherSubscriber.Builder<T> enableLogging()

Enables logging signals, with the default logger name. The default is disabled.

Returns:

this.

enableLogging

public TestPublisherSubscriber.Builder<T> enableLogging(java.lang.String loggingName)

Enables logging signals, with the specified logger name. The default is disabled.

Parameters:

loggingName - The logger name to use

Returns:

this.

disableLogging

public TestPublisherSubscriber.Builder<T> disableLogging()

Disables logging signals. The default is disabled.

Returns:

this.

build

public TestPublisherSubscriber<T> build()

Create a TestPublisherSubscriber as configured by the builder.

Returns:

a new TestPublisherSubscriber.