T
- Type of the items emitted by the TestPublisher
.public static class TestPublisher.Builder<T>
extends java.lang.Object
TestPublisher
s with non-default settings. For defaults, see Defaults section
of class javadoc.Constructor and Description |
---|
Builder() |
Modifier and Type | Method and Description |
---|---|
TestPublisher.Builder<T> |
autoOnSubscribe()
Enable calling
Subscriber#onSubscribe(Subscription) automatically upon subscribe. |
TestPublisher.Builder<T> |
autoOnSubscribe(AutoOnSubscribePublisherSubscriberFunction<T> function)
Enable calling
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
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 . |
public TestPublisher.Builder<T> concurrentSubscribers()
ConcurrentPublisherSubscriberFunction
public TestPublisher.Builder<T> concurrentSubscribers(ConcurrentPublisherSubscriberFunction<T> function)
ConcurrentPublisherSubscriberFunction
.
Default is to allow only sequential subscribers.function
- the ConcurrentPublisherSubscriberFunction
to use.public TestPublisher.Builder<T> sequentialSubscribers()
SequentialPublisherSubscriberFunction
public TestPublisher.Builder<T> sequentialSubscribers(SequentialPublisherSubscriberFunction<T> function)
SequentialPublisherSubscriberFunction
.
This is the default.function
- the SequentialPublisherSubscriberFunction
to use.public TestPublisher.Builder<T> singleSubscriber()
NonResubscribeablePublisherSubscriberFunction
public TestPublisher.Builder<T> singleSubscriber(NonResubscribeablePublisherSubscriberFunction<T> function)
NonResubscribeablePublisherSubscriberFunction
.
Default is to allow sequential subscribers.function
- the NonResubscribeablePublisherSubscriberFunction
to use.public TestPublisher.Builder<T> enableDemandCheck()
DemandCheckingSubscriber
public TestPublisher.Builder<T> enableDemandCheck(DemandCheckingSubscriberFunction<T> function)
DemandCheckingSubscriberFunction
. The default is enabled.function
- the DemandCheckingSubscriberFunction
to use.public TestPublisher.Builder<T> disableDemandCheck()
public TestPublisher.Builder<T> autoOnSubscribe()
Subscriber#onSubscribe(Subscription)
automatically upon subscribe. The default is
enabled.AutoOnSubscribePublisherSubscriberFunction
public TestPublisher.Builder<T> autoOnSubscribe(AutoOnSubscribePublisherSubscriberFunction<T> function)
Subscriber#onSubscribe(Subscription)
automatically upon subscribe, with the specified
AutoOnSubscribePublisherSubscriberFunction
. The default is enabled.function
- the AutoOnSubscribePublisherSubscriberFunction
to use.public TestPublisher.Builder<T> disableAutoOnSubscribe()
Subscriber#onSubscribe(Subscription)
automatically upon subscribe. The default is
enabled.public TestPublisher<T> build(java.util.function.Function<PublisherSource.Subscriber<? super T>,PublisherSource.Subscriber<? super T>> function)
TestPublisher
using the specified subscriber function.
All other settings from this TestPublisher.Builder
will be ignored.
function
- The subscriber function to use.TestPublisher
.public TestPublisher<T> build()
TestPublisher
as configured by the builder.TestPublisher
.