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 theTestSingle
.
- Enclosing class:
- TestSingle<T>
public static class TestSingle.Builder<T> extends java.lang.Object
Allows for creatingTestSingle
s with non-default settings. For defaults, see Defaults section of class javadoc.
-
-
Constructor Summary
Constructors Constructor Description Builder()
-
Method Summary
-
-
-
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 specifiedConcurrentSingleSubscriberFunction
. Default is to allow only sequential subscribers.- Parameters:
function
- theConcurrentSingleSubscriberFunction
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 specifiedSequentialSingleSubscriberFunction
. This is the default.- Parameters:
function
- theSequentialSingleSubscriberFunction
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 specifiedNonResubscribeableSingleSubscriberFunction
. Default is to allow sequential subscribers.- Parameters:
function
- theNonResubscribeableSingleSubscriberFunction
to use.- Returns:
- this.
-
autoOnSubscribe
public TestSingle.Builder<T> autoOnSubscribe()
Enable callingSingleSource.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 callingSingleSource.Subscriber.onSubscribe(Cancellable)
automatically upon subscribe, with the specifiedAutoOnSubscribeSingleSubscriberFunction
. The default is enabled.- Parameters:
function
- theAutoOnSubscribeSingleSubscriberFunction
to use.- Returns:
- this.
-
disableAutoOnSubscribe
public TestSingle.Builder<T> disableAutoOnSubscribe()
Disable callingSingleSource.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 aTestSingle
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 aTestSingle
as configured by the builder.- Returns:
- a new
TestSingle
.
-
-