public final Class MaybeFromRunnable<T>

Class Inheritance

extends Maybe<T>
implements Callable<T>

java.lang.Object
io.reactivex.Maybe
io.reactivex.internal.operators.maybe.MaybeFromRunnable

All Implemented Interfaces

java.util.concurrent.Callable

Type Parameters

<T>: the value type

Imports

java.util.concurrent.Callable, io.reactivex.*, io.reactivex.disposables.*, io.reactivex.exceptions.Exceptions, io.reactivex.plugins.RxJavaPlugins

Executes an Runnable and signals its exception or completes normally.

Field Summary

Modifier and Type	Field and Description
pack-priv final Runnable	runnable

Constructor Summary

Access	Constructor and Description
public	MaybeFromRunnable(Runnable runnable)

Method Summary

Modifier and Type	Method and Description
public T	call() Implements java.util.concurrent.Callable.call. Computes a result, or throws an exception if unable to do so.
protected void	subscribeActual(MaybeObserver<? super T> the MaybeObserver to handle, not null observer) Implements abstract io.reactivex.Maybe.subscribeActual. Implement this method in subclasses to handle the incoming `MaybeObserver`s.

Inherited from io.reactivex.Maybe:: amb ambArray ambWith as blockingGet blockingGet cache cast compose concat concat concat concat concat concat concatArray concatArrayDelayError concatArrayEager concatDelayError concatDelayError concatEager concatEager concatMap concatWith contains count create defaultIfEmpty defer delay delay delay delaySubscription delaySubscription delaySubscription doAfterSuccess doAfterTerminate doFinally doOnComplete doOnDispose doOnError doOnEvent doOnSubscribe doOnSuccess doOnTerminate empty error error filter flatMap flatMap flatMap flatMapCompletable flatMapObservable flatMapPublisher flatMapSingle flatMapSingleElement flattenAsFlowable flattenAsObservable fromAction fromCallable fromCompletable fromFuture fromFuture fromRunnable fromSingle hide ignoreElement isEmpty just lift map materialize merge merge merge merge merge merge merge mergeArray mergeArrayDelayError mergeDelayError mergeDelayError mergeDelayError mergeDelayError mergeDelayError mergeDelayError mergeWith never observeOn ofType onErrorComplete onErrorComplete onErrorResumeNext onErrorResumeNext onErrorReturn onErrorReturnItem onExceptionResumeNext onTerminateDetach repeat repeat repeatUntil repeatWhen retry retry retry retry retry retryUntil retryWhen sequenceEqual sequenceEqual subscribe subscribe subscribe subscribe subscribe subscribeOn subscribeWith switchIfEmpty switchIfEmpty takeUntil takeUntil test test timeout timeout timeout timeout timeout timeout timeout timeout timer timer to toFlowable toObservable toSingle toSingle unsafeCreate unsubscribeOn using using wrap zip zip zip zip zip zip zip zip zip zipArray zipWith

Field Detail

runnable	back to summary
pack-priv final Runnable runnable

Constructor Detail

MaybeFromRunnable	back to summary
public MaybeFromRunnable(Runnable runnable)

Method Detail

call	back to summary
public T call() throws Exception Implements java.util.concurrent.Callable.call. Doc from java.util.concurrent.Callable.call. Computes a result, or throws an exception if unable to do so. Returns:T computed result Annotations @Override Exceptions Exception: if unable to compute a result

call

back to summary

public T call() throws Exception

Implements java.util.concurrent.Callable.call.

Doc from java.util.concurrent.Callable.call.

Computes a result, or throws an exception if unable to do so.

Returns:T

computed result

Annotations

@Override

Exceptions

Exception:: if unable to compute a result

subscribeActual back to summary

subscribeActual	back to summary
protected void subscribeActual(MaybeObserver<? super T> observer) Implements abstract io.reactivex.Maybe.subscribeActual. Doc from io.reactivex.Maybe.subscribeActual. Implement this method in subclasses to handle the incoming `MaybeObserver`s. There is no need to call any of the plugin hooks on the current `Maybe` instance or the `MaybeObserver`; all hooks and basic safeguards have been applied by `subscribe(MaybeObserver)` before this method gets called. Parameters observer:MaybeObserver<? super T> the MaybeObserver to handle, not null Annotations @Override

protected void subscribeActual(MaybeObserver<? super T> observer)

Implements abstract io.reactivex.Maybe.subscribeActual.

Doc from io.reactivex.Maybe.subscribeActual.

Implement this method in subclasses to handle the incoming MaybeObservers.

There is no need to call any of the plugin hooks on the current Maybe instance or the MaybeObserver; all hooks and basic safeguards have been applied by subscribe(MaybeObserver) before this method gets called.

Parameters

observer:MaybeObserver<? super T>: the MaybeObserver to handle, not null

Annotations

@Override