hu.akarnokd.rxjava3.basetypes

Class SoloProcessor<T>

java.lang.Object

hu.akarnokd.rxjava3.basetypes.Solo<T>

hu.akarnokd.rxjava3.basetypes.SoloProcessor<T>

Type Parameters:

T - the input and output value type

All Implemented Interfaces:

Processor<T,T>, Publisher<T>, Subscriber<T>

public final class SoloProcessor<T>
extends Solo<T>
implements Processor<T,T>

A Processor based on the Solo type that emits an onNext+onComplete or an onError.

Calling the onNext multiple times has no effect. Calling the onComplete without calling the onNext will emit a NoSuchElementException to subscribers.

Since:

0.13.0

Method Summary

Modifier and Type	Method and Description
static <T> SoloProcessor<T>	create() Creates a fresh SoloProcessor instance.
Throwable	getThrowable() Returns the received onError Throwable if hasThrowable() is true, null otherwise.
T	getValue() Returns the received onNext value if hasValue() is true, null otherwise.
boolean	hasSubscribers() Returns true if this Processor has Subscribers.
boolean	hasThrowable() Returns true if this SoloProcessor received an onError Throwable.
boolean	hasValue() Returns true if this SoloProcessor received an onNext value.
void	onComplete()
void	onError(Throwable t)
void	onNext(T t)
void	onSubscribe(Subscription s)
protected void	subscribeActual(Subscriber<? super T> s) Implement this method to react to a Subscriber subscribing to this Solo.

Methods inherited from class hu.akarnokd.rxjava3.basetypes.Solo

amb, ambArray, ambWith, andThen, andThen, blockingGet, blockingGet, blockingSubscribe, blockingSubscribe, blockingSubscribe, blockingSubscribe, cache, compose, concat, concat, concat, concatArray, concatArrayDelayError, concatDelayError, concatDelayError, concatDelayError, concatDelayError, concatWith, create, defer, delay, delay, delay, delaySubscription, delaySubscription, delaySubscription, doAfterNext, doAfterTerminate, doFinally, doOnCancel, doOnComplete, doOnError, doOnNext, doOnRequest, doOnSubscribe, error, error, filter, flatMap, flatMap, flatMapPublisher, fromCallable, fromFuture, fromFuture, fromPublisher, fromSingle, getOnAssemblyHandler, hide, ignoreElement, just, lift, map, mapError, merge, merge, merge, merge, mergeArray, mergeArray, mergeArrayDelayError, mergeArrayDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeWith, never, observeOn, onAssembly, onErrorResumeNext, onErrorResumeWith, onErrorReturnItem, repeat, repeat, repeat, repeatWhen, retry, retry, retry, retryWhen, setOnAssemblyHandler, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscribeWith, takeUntil, test, test, test, test, timeout, timeout, timeout, timeout, timeout, timeout, timer, timer, to, toFlowable, toFuture, toObservable, toSingle, unsubscribeOn, using, using, zip, zipArray, zipWith

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.reactivestreams.Publisher

subscribe

Method Detail

create

public static <T> SoloProcessor<T> create()

Creates a fresh SoloProcessor instance.

Type Parameters:

T - the input and output value type

Returns:

the new SoloProcessor instance

subscribeActual

protected void subscribeActual(Subscriber<? super T> s)

Description copied from class: Solo

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

Specified by:

subscribeActual in class Solo<T>

Parameters:

s - the downstream Subscriber, never null

onSubscribe

public void onSubscribe(Subscription s)

Specified by:

onSubscribe in interface Subscriber<T>

onNext

public void onNext(T t)

Specified by:

onNext in interface Subscriber<T>

onError

public void onError(Throwable t)

Specified by:

onError in interface Subscriber<T>

onComplete

public void onComplete()

Specified by:

onComplete in interface Subscriber<T>

hasSubscribers

public boolean hasSubscribers()

Returns true if this Processor has Subscribers.

Returns:

true if this Processor has Subscribers

hasValue

public boolean hasValue()

Returns true if this SoloProcessor received an onNext value.

Returns:

true if this SoloProcessor received an onNext value

getValue

public T getValue()

Returns the received onNext value if hasValue() is true, null otherwise.

Returns:

the received onNext value if hasValue() is true, null otherwise

hasThrowable

public boolean hasThrowable()

Returns true if this SoloProcessor received an onError Throwable.

Returns:

true if this SoloProcessor received an onError Throwable

getThrowable

public Throwable getThrowable()

Returns the received onError Throwable if hasThrowable() is true, null otherwise.

Returns:

the received onError Throwable if hasThrowable() is true, null otherwise