Top Description Inners Fields Constructors Methods
io.reactivex.internal.operators.maybe

public final Class MaybeCreate<T>

extends Maybe<T>
Class Inheritance
Type Parameters
<T>
the value type emitted
Imports
java.util.concurrent.atomic.AtomicReference, io.reactivex.*, io.reactivex.disposables.Disposable, io.reactivex.exceptions.Exceptions, io.reactivex.functions.Cancellable, io.reactivex.internal.disposables.*, io.reactivex.plugins.RxJavaPlugins
Provides an API over MaybeObserver that serializes calls to onXXX and manages cancellation in a safe manner.

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
MaybeCreate.Emitter<T>

Field Summary

Modifier and TypeField and Description
pack-priv final MaybeOnSubscribe<T>
source

Constructor Summary

AccessConstructor and Description
public
MaybeCreate(MaybeOnSubscribe<T> source)

Method Summary

Modifier and TypeMethod and Description
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 MaybeObservers.
Inherited from io.reactivex.Maybe:
ambambArrayambWithasblockingGetblockingGetcachecastcomposeconcatconcatconcatconcatconcatconcatconcatArrayconcatArrayDelayErrorconcatArrayEagerconcatDelayErrorconcatDelayErrorconcatEagerconcatEagerconcatMapconcatWithcontainscountcreatedefaultIfEmptydeferdelaydelaydelaydelaySubscriptiondelaySubscriptiondelaySubscriptiondoAfterSuccessdoAfterTerminatedoFinallydoOnCompletedoOnDisposedoOnErrordoOnEventdoOnSubscribedoOnSuccessdoOnTerminateemptyerrorerrorfilterflatMapflatMapflatMapflatMapCompletableflatMapObservableflatMapPublisherflatMapSingleflatMapSingleElementflattenAsFlowableflattenAsObservablefromActionfromCallablefromCompletablefromFuturefromFuturefromRunnablefromSinglehideignoreElementisEmptyjustliftmapmaterializemergemergemergemergemergemergemergemergeArraymergeArrayDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeWithneverobserveOnofTypeonErrorCompleteonErrorCompleteonErrorResumeNextonErrorResumeNextonErrorReturnonErrorReturnItemonExceptionResumeNextonTerminateDetachrepeatrepeatrepeatUntilrepeatWhenretryretryretryretryretryretryUntilretryWhensequenceEqualsequenceEqualsubscribesubscribesubscribesubscribesubscribesubscribeOnsubscribeWithswitchIfEmptyswitchIfEmptytakeUntiltakeUntiltesttesttimeouttimeouttimeouttimeouttimeouttimeouttimeouttimeouttimertimertotoFlowabletoObservabletoSingletoSingleunsafeCreateunsubscribeOnusingusingwrapzipzipzipzipzipzipzipzipzipzipArrayzipWith

Field Detail

sourceback to summary
pack-priv final MaybeOnSubscribe<T> source

Constructor Detail

MaybeCreateback to summary
public MaybeCreate(MaybeOnSubscribe<T> source)

Method Detail

subscribeActualback 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 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
io.reactivex.internal.operators.maybe back to summary

pack-priv final Class MaybeCreate.Emitter<T>

extends AtomicReference<Disposable>
implements MaybeEmitter<T>, Disposable
Class Inheritance
All Implemented Interfaces
io.reactivex.disposables.Disposable, io.reactivex.MaybeEmitter

Field Summary

Modifier and TypeField and Description
pack-priv final MaybeObserver<? super T>
downstream

private static final long
serialVersionUID

Hides java.util.concurrent.atomic.AtomicReference.serialVersionUID.

Constructor Summary

AccessConstructor and Description
pack-priv
Emitter(MaybeObserver<? super T> downstream)

Method Summary

Modifier and TypeMethod and Description
public void
dispose()

Implements io.reactivex.disposables.Disposable.dispose.

Dispose the resource, the operation should be idempotent.
public boolean
isDisposed()

Implements io.reactivex.MaybeEmitter.isDisposed, io.reactivex.disposables.Disposable.isDisposed.

Returns true if the downstream disposed the sequence or the emitter was terminated via onSuccess(Object), onError(Throwable), onComplete or a successful tryOnError(Throwable).
public void
onComplete()

Implements io.reactivex.MaybeEmitter.onComplete.

Signal the completion.
public void
onError(Throwable
the exception, not null
t)

Implements io.reactivex.MaybeEmitter.onError.

Signal an exception.
public void
onSuccess(T
the value, not null
value)

Implements io.reactivex.MaybeEmitter.onSuccess.

Signal a success value.
public void
setCancellable(Cancellable
the cancellable resource, null is allowed
c)

Implements io.reactivex.MaybeEmitter.setCancellable.

Sets a Cancellable on this emitter; any previous Disposable or Cancellable will be disposed/cancelled.
public void
setDisposable(Disposable
the disposable, null is allowed
d)

Implements io.reactivex.MaybeEmitter.setDisposable.

Sets a Disposable on this emitter; any previous Disposable or Cancellable will be disposed/cancelled.
public String
toString()

Overrides java.util.concurrent.atomic.AtomicReference.toString.

Returns the String representation of the current value.
public boolean
tryOnError(Throwable
the throwable error to signal if possible
t)

Implements io.reactivex.MaybeEmitter.tryOnError.

Attempts to emit the specified Throwable error if the downstream hasn't cancelled the sequence or is otherwise terminated, returning false if the emission is not allowed to happen due to lifecycle restrictions.
Inherited from java.util.concurrent.atomic.AtomicReference:
accumulateAndGetcompareAndExchangecompareAndExchangeAcquirecompareAndExchangeReleasecompareAndSetgetgetAcquiregetAndAccumulategetAndSetgetAndUpdategetOpaquegetPlainlazySetsetsetOpaquesetPlainsetReleaseupdateAndGetweakCompareAndSetweakCompareAndSetAcquireweakCompareAndSetPlainweakCompareAndSetReleaseweakCompareAndSetVolatile

Field Detail

downstreamback to summary
pack-priv final MaybeObserver<? super T> downstream
serialVersionUIDback to summary
private static final long serialVersionUID

Hides java.util.concurrent.atomic.AtomicReference.serialVersionUID.

Constructor Detail

Emitterback to summary
pack-priv Emitter(MaybeObserver<? super T> downstream)

Method Detail

disposeback to summary
public void dispose()

Implements io.reactivex.disposables.Disposable.dispose.

Doc from io.reactivex.disposables.Disposable.dispose.

Dispose the resource, the operation should be idempotent.

Annotations
@Override
isDisposedback to summary
public boolean isDisposed()

Implements io.reactivex.MaybeEmitter.isDisposed, io.reactivex.disposables.Disposable.isDisposed.

Doc from io.reactivex.MaybeEmitter.isDisposed.

Returns true if the downstream disposed the sequence or the emitter was terminated via onSuccess(Object), onError(Throwable), onComplete or a successful tryOnError(Throwable).

This method is thread-safe.

Returns:boolean

true if the downstream disposed the sequence or the emitter was terminated

Annotations
@Override
onCompleteback to summary
public void onComplete()

Implements io.reactivex.MaybeEmitter.onComplete.

Doc from io.reactivex.MaybeEmitter.onComplete.

Signal the completion.

Annotations
@Override
onErrorback to summary
public void onError(Throwable t)

Implements io.reactivex.MaybeEmitter.onError.

Doc from io.reactivex.MaybeEmitter.onError.

Signal an exception.

Parameters
t:Throwable

the exception, not null

Annotations
@Override
onSuccessback to summary
public void onSuccess(T value)

Implements io.reactivex.MaybeEmitter.onSuccess.

Doc from io.reactivex.MaybeEmitter.onSuccess.

Signal a success value.

Parameters
value:T

the value, not null

Annotations
@Override
setCancellableback to summary
public void setCancellable(Cancellable c)

Implements io.reactivex.MaybeEmitter.setCancellable.

Doc from io.reactivex.MaybeEmitter.setCancellable.

Sets a Cancellable on this emitter; any previous Disposable or Cancellable will be disposed/cancelled.

Parameters
c:Cancellable

the cancellable resource, null is allowed

Annotations
@Override
setDisposableback to summary
public void setDisposable(Disposable d)

Implements io.reactivex.MaybeEmitter.setDisposable.

Doc from io.reactivex.MaybeEmitter.setDisposable.

Sets a Disposable on this emitter; any previous Disposable or Cancellable will be disposed/cancelled.

Parameters
d:Disposable

the disposable, null is allowed

Annotations
@Override
toStringback to summary
public String toString()

Overrides java.util.concurrent.atomic.AtomicReference.toString.

Doc from java.util.concurrent.atomic.AtomicReference.toString.

Returns the String representation of the current value.

Returns:String

the String representation of the current value

Annotations
@Override
tryOnErrorback to summary
public boolean tryOnError(Throwable t)

Implements io.reactivex.MaybeEmitter.tryOnError.

Doc from io.reactivex.MaybeEmitter.tryOnError.

Attempts to emit the specified Throwable error if the downstream hasn't cancelled the sequence or is otherwise terminated, returning false if the emission is not allowed to happen due to lifecycle restrictions.

Unlike onError(Throwable), the RxJavaPlugins.onError is not called if the error could not be delivered.

History: 2.1.1 - experimental

Parameters
t:Throwable

the throwable error to signal if possible

Returns:boolean

true if successful, false if the downstream is not able to accept further events

Annotations
@Override