RxJava 2 2.2.21 · io.reactivex.processors.FlowableProcessor

Access	Constructor and Description
public	FlowableProcessor()

Method Summary

Modifier and Type	Method and Description
public abstract Throwable	Returns: the error that caused the FlowableProcessor to terminate or null if the FlowableProcessor hasn't terminated yet getThrowable() Returns the error that caused the FlowableProcessor to terminate or null if the FlowableProcessor hasn't terminated yet.
public abstract boolean	Returns: true if the FlowableProcessor has reached a terminal state through a complete event hasComplete() Returns true if the FlowableProcessor has reached a terminal state through a complete event.
public abstract boolean	Returns: true if the FlowableProcessor has subscribers hasSubscribers() Returns true if the FlowableProcessor has subscribers.
public abstract boolean	Returns: true if the FlowableProcessor has reached a terminal state through an error event hasThrowable() Returns true if the FlowableProcessor has reached a terminal state through an error event.
public final FlowableProcessor<T>	Returns: the wrapped and serialized FlowableProcessor toSerialized() Wraps this FlowableProcessor and serializes the calls to the onSubscribe, onNext, onError and onComplete methods, making them thread-safe.

Inherited from io.reactivex.Flowable:: all amb ambArray ambWith any as blockingFirst blockingFirst blockingForEach blockingIterable blockingIterable blockingLast blockingLast blockingLatest blockingMostRecent blockingNext blockingSingle blockingSingle blockingSubscribe blockingSubscribe blockingSubscribe blockingSubscribe blockingSubscribe blockingSubscribe blockingSubscribe blockingSubscribe buffer buffer buffer buffer buffer buffer buffer buffer buffer buffer buffer buffer buffer buffer buffer buffer buffer buffer buffer bufferSize cache cacheWithInitialCapacity cast collect collectInto combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatestDelayError combineLatestDelayError combineLatestDelayError combineLatestDelayError combineLatestDelayError combineLatestDelayError compose concat concat concat concat concat concat concatArray concatArrayDelayError concatArrayEager concatArrayEager concatArrayEagerDelayError concatArrayEagerDelayError concatDelayError concatDelayError concatDelayError concatEager concatEager concatEager concatEager concatMap concatMap concatMapCompletable concatMapCompletable concatMapCompletableDelayError concatMapCompletableDelayError concatMapCompletableDelayError concatMapDelayError concatMapDelayError concatMapEager concatMapEager concatMapEagerDelayError concatMapEagerDelayError concatMapIterable concatMapIterable concatMapMaybe concatMapMaybe concatMapMaybeDelayError concatMapMaybeDelayError concatMapMaybeDelayError concatMapSingle concatMapSingle concatMapSingleDelayError concatMapSingleDelayError concatMapSingleDelayError concatWith concatWith concatWith concatWith contains count create debounce debounce debounce defaultIfEmpty defer delay delay delay delay delay delay delaySubscription delaySubscription delaySubscription dematerialize dematerialize distinct distinct distinct distinctUntilChanged distinctUntilChanged distinctUntilChanged doAfterNext doAfterTerminate doFinally doOnCancel doOnComplete doOnEach doOnEach doOnError doOnLifecycle doOnNext doOnRequest doOnSubscribe doOnTerminate elementAt elementAt elementAtOrError empty error error filter first firstElement firstOrError flatMap flatMap flatMap flatMap flatMap flatMap flatMap flatMap flatMap flatMap flatMap flatMap flatMapCompletable flatMapCompletable flatMapIterable flatMapIterable flatMapIterable flatMapIterable flatMapMaybe flatMapMaybe flatMapSingle flatMapSingle forEach forEachWhile forEachWhile forEachWhile fromArray fromCallable fromFuture fromFuture fromFuture fromFuture fromIterable fromPublisher generate generate generate generate generate groupBy groupBy groupBy groupBy groupBy groupBy groupJoin hide ignoreElements interval interval interval interval intervalRange intervalRange isEmpty join just just just just just just just just just just last lastElement lastOrError lift limit map materialize merge merge merge merge merge merge merge merge mergeArray mergeArray mergeArrayDelayError mergeArrayDelayError mergeDelayError mergeDelayError mergeDelayError mergeDelayError mergeDelayError mergeDelayError mergeDelayError mergeDelayError mergeWith mergeWith mergeWith mergeWith never observeOn observeOn observeOn ofType onBackpressureBuffer onBackpressureBuffer onBackpressureBuffer onBackpressureBuffer onBackpressureBuffer onBackpressureBuffer onBackpressureBuffer onBackpressureBuffer onBackpressureDrop onBackpressureDrop onBackpressureLatest onErrorResumeNext onErrorResumeNext onErrorReturn onErrorReturnItem onExceptionResumeNext onTerminateDetach parallel parallel parallel publish publish publish publish range rangeLong rebatchRequests reduce reduce reduceWith repeat repeat repeatUntil repeatWhen replay replay replay replay replay replay replay replay replay replay replay replay replay replay replay replay retry retry retry retry retry retryUntil retryWhen safeSubscribe sample sample sample sample sample sample scan scan scanWith sequenceEqual sequenceEqual sequenceEqual sequenceEqual serialize share single singleElement singleOrError skip skip skip skipLast skipLast skipLast skipLast skipLast skipLast skipUntil skipWhile sorted sorted startWith startWith startWith startWithArray subscribe subscribe subscribe subscribe subscribe subscribe subscribe subscribeActual subscribeOn subscribeOn subscribeWith switchIfEmpty switchMap switchMap switchMapCompletable switchMapCompletableDelayError switchMapDelayError switchMapDelayError switchMapMaybe switchMapMaybeDelayError switchMapSingle switchMapSingleDelayError switchOnNext switchOnNext switchOnNextDelayError switchOnNextDelayError take take take takeLast takeLast takeLast takeLast takeLast takeLast takeLast takeLast takeLast takeUntil takeUntil takeWhile test test test throttleFirst throttleFirst throttleLast throttleLast throttleLatest throttleLatest throttleLatest throttleLatest throttleWithTimeout throttleWithTimeout timeInterval timeInterval timeInterval timeInterval timeout timeout timeout timeout timeout timeout timeout timeout timer timer timestamp timestamp timestamp timestamp to toFuture toList toList toList toMap toMap toMap toMultimap toMultimap toMultimap toMultimap toObservable toSortedList toSortedList toSortedList toSortedList unsafeCreate unsubscribeOn using using window window window window window window window window window window window window window window window window window window window withLatestFrom withLatestFrom withLatestFrom withLatestFrom withLatestFrom withLatestFrom zip zip zip zip zip zip zip zip zip zip zip zip zipArray zipIterable zipWith zipWith zipWith zipWith

FlowableProcessor	back to summary
public FlowableProcessor()

Method Detail

getThrowable	back to summary
public abstract Throwable getThrowable() Returns the error that caused the FlowableProcessor to terminate or null if the FlowableProcessor hasn't terminated yet. The method is thread-safe. Returns:Throwable the error that caused the FlowableProcessor to terminate or null if the FlowableProcessor hasn't terminated yet Annotations @Nullable

getThrowable

back to summary

public abstract Throwable getThrowable()

Returns the error that caused the FlowableProcessor to terminate or null if the FlowableProcessor hasn't terminated yet.

The method is thread-safe.

Returns:Throwable

the error that caused the FlowableProcessor to terminate or null if the FlowableProcessor hasn't terminated yet

Annotations

@Nullable

hasComplete back to summary

hasComplete	back to summary
public abstract boolean hasComplete() Returns true if the FlowableProcessor has reached a terminal state through a complete event. The method is thread-safe. Returns:boolean true if the FlowableProcessor has reached a terminal state through a complete event See Also `hasThrowable()`

public abstract boolean hasComplete()

Returns true if the FlowableProcessor has reached a terminal state through a complete event.

The method is thread-safe.

Returns:boolean: true if the FlowableProcessor has reached a terminal state through a complete event
See Also: hasThrowable()

hasSubscribers	back to summary
public abstract boolean hasSubscribers() Returns true if the FlowableProcessor has subscribers. The method is thread-safe. Returns:boolean true if the FlowableProcessor has subscribers

hasSubscribers

back to summary

public abstract boolean hasSubscribers()

Returns true if the FlowableProcessor has subscribers.

The method is thread-safe.

Returns:boolean: true if the FlowableProcessor has subscribers

hasThrowable back to summary

hasThrowable	back to summary
public abstract boolean hasThrowable() Returns true if the FlowableProcessor has reached a terminal state through an error event. The method is thread-safe. Returns:boolean true if the FlowableProcessor has reached a terminal state through an error event See Also `getThrowable()`, `hasComplete()`

public abstract boolean hasThrowable()

Returns true if the FlowableProcessor has reached a terminal state through an error event.

The method is thread-safe.

Returns:boolean: true if the FlowableProcessor has reached a terminal state through an error event
See Also: getThrowable(), hasComplete()

toSerialized	back to summary
public final FlowableProcessor<T> toSerialized() Wraps this FlowableProcessor and serializes the calls to the onSubscribe, onNext, onError and onComplete methods, making them thread-safe. The method is thread-safe. Returns:FlowableProcessor<T> the wrapped and serialized FlowableProcessor Annotations @NonNull @CheckReturnValue

toSerialized

back to summary

public final FlowableProcessor<T> toSerialized()

Wraps this FlowableProcessor and serializes the calls to the onSubscribe, onNext, onError and onComplete methods, making them thread-safe.

The method is thread-safe.

Returns:FlowableProcessor<T>

the wrapped and serialized FlowableProcessor

Annotations

@NonNull
@CheckReturnValue

public abstract Class FlowableProcessor<T>

Constructor Summary

Method Summary

Constructor Detail

Method Detail