hu.akarnokd.rxjava2.basetypes

Class Perhaps<T>

java.lang.Object

hu.akarnokd.rxjava2.basetypes.Perhaps<T>

Type Parameters:

T - the value type

All Implemented Interfaces:

org.reactivestreams.Publisher<T>

public abstract class Perhaps<T>
extends java.lang.Object
implements org.reactivestreams.Publisher<T>

A 0-1-error base reactive type, similar to Maybe, implementing the Reactive-Streams Publisher interface.

Since:

0.14.0

Constructor Summary

Constructors

Constructor and Description
Perhaps()

Method Summary

Modifier and Type	Method and Description
static <T> io.reactivex.functions.Function<Perhaps<T>,Perhaps<T>>	getOnAssemblyHandler() Returns the current onAssembly handler.
protected static <T> Perhaps<T>	onAssembly(Perhaps<T> source)
static <T> void	setOnAssemblyHandler(io.reactivex.functions.Function<Perhaps<T>,Perhaps<T>> handler) Set the onAssembly handler.
void	subscribe(org.reactivestreams.Subscriber<? super T> s)
protected abstract void	subscribeActual(org.reactivestreams.Subscriber<? super T> s) Implement this method to react to a Subscriber subscribing to this Perhaps.
io.reactivex.subscribers.TestSubscriber<T>	test() Creates a TestSubscriber and subscribes it to this Perhaps.
io.reactivex.subscribers.TestSubscriber<T>	test(boolean cancel) Creates a TestSubscriber, optionally cancels it, and subscribes it to this Perhaps.
io.reactivex.subscribers.TestSubscriber<T>	test(long initialRequest) Creates a TestSubscriber with the given initial request and subscribes it to this Perhaps.
io.reactivex.subscribers.TestSubscriber<T>	test(long initialRequest, boolean cancel) Creates a TestSubscriber with the given initial request, optionally cancels it, and subscribes it to this Perhaps.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Perhaps

public Perhaps()

Method Detail

getOnAssemblyHandler

public static <T> io.reactivex.functions.Function<Perhaps<T>,Perhaps<T>> getOnAssemblyHandler()

Returns the current onAssembly handler.

Type Parameters:

T - the target value type

Returns:

the current handler, maybe null

setOnAssemblyHandler

public static <T> void setOnAssemblyHandler(io.reactivex.functions.Function<Perhaps<T>,Perhaps<T>> handler)

Set the onAssembly handler.

Type Parameters:

T - the target value type

Parameters:

handler - the handler, null clears the handler

onAssembly

protected static <T> Perhaps<T> onAssembly(Perhaps<T> source)

subscribe

public final void subscribe(org.reactivestreams.Subscriber<? super T> s)

Specified by:

subscribe in interface org.reactivestreams.Publisher<T>

subscribeActual

protected abstract void subscribeActual(org.reactivestreams.Subscriber<? super T> s)

Implement this method to react to a Subscriber subscribing to this Perhaps.

Parameters:

s - the downstream Subscriber, never null

test

public final io.reactivex.subscribers.TestSubscriber<T> test()

Creates a TestSubscriber and subscribes it to this Perhaps.

Returns:

the new TestSubscriber instance

test

public final io.reactivex.subscribers.TestSubscriber<T> test(boolean cancel)

Creates a TestSubscriber, optionally cancels it, and subscribes it to this Perhaps.

Parameters:

cancel - if true, the TestSubscriber will be cancelled before subscribing to this Perhaps

Returns:

the new TestSubscriber instance

test

public final io.reactivex.subscribers.TestSubscriber<T> test(long initialRequest)

Creates a TestSubscriber with the given initial request and subscribes it to this Perhaps.

Parameters:

initialRequest - the initial request amount, non-negative

Returns:

the new TestSubscriber

test

public final io.reactivex.subscribers.TestSubscriber<T> test(long initialRequest,
                                                             boolean cancel)

Creates a TestSubscriber with the given initial request, optionally cancels it, and subscribes it to this Perhaps.

Parameters:

initialRequest - the initial request amount, non-negative

cancel - if true, the TestSubscriber will be cancelled before subscribing to this Perhaps

Returns:

the new TestSubscriber