RxJava 2 2.2.21 · io.reactivex.internal.fuseable

Interface Summary

Modifier and Type	Interface and Description
public interface	ConditionalSubscriber< the value type T> A Subscriber with an additional `tryOnNext(Object)` method that tells the caller the specified value has been accepted or not.
public interface	FuseToFlowable< the value type T> Interface indicating a operator implementation can be macro-fused back to Flowable in case the operator goes from Flowable to some other reactive type and then the sequence calls for toFlowable again: Single<Integer> single = Flowable.range(1, 10).reduce((a, b) -> a + b); Flowable<Integer> flowable = single.toFlowable();
public interface	FuseToMaybe< the value type T> Interface indicating an operator implementation can be macro-fused back to Maybe in case the operator goes from Maybe to some other reactive type and then the sequence calls for toMaybe again: Single<Integer> single = Maybe.just(1).isEmpty(); Maybe<Integer> maybe = single.toMaybe();
public interface	FuseToObservable< the value type T> Interface indicating a operator implementation can be macro-fused back to Observable in case the operator goes from Observable to some other reactive type and then the sequence calls for toObservable again: Single<Integer> single = Observable.range(1, 10).reduce((a, b) -> a + b); Observable<Integer> observable = single.toObservable();
public interface	HasUpstreamCompletableSource Interface indicating the implementor has an upstream CompletableSource-like source available via `source()` method.
public interface	HasUpstreamMaybeSource< the value type T> Interface indicating the implementor has an upstream MaybeSource-like source available via `source()` method.
public interface	HasUpstreamObservableSource< the value type T> Interface indicating the implementor has an upstream ObservableSource-like source available via `source()` method.
public interface	HasUpstreamPublisher< the value type T> Interface indicating the implementor has an upstream Publisher-like source available via `source()` method.
public interface	HasUpstreamSingleSource< the value type T> Interface indicating the implementor has an upstream SingleSource-like source available via `source()` method.
public interface	QueueDisposable< the value type transmitted through the queue T> An interface extending Queue and Disposable and allows negotiating the fusion mode between subsequent operators of the `Observable` base reactive type.
public interface	QueueFuseable< the value type returned by the SimpleQueue.poll() T> Represents a SimpleQueue plus the means and constants for requesting a fusion mode.
public interface	QueueSubscription< the value type transmitted through the queue T> An interface extending Queue and Subscription and allows negotiating the fusion mode between subsequent operators of the `Flowable` base reactive type.
public interface	ScalarCallable< the scalar value type held by the implementing reactive type T> A marker interface indicating that a scalar, constant value is held by the implementing reactive type which can be safely extracted during assembly time can be used for optimization.
public interface	SimplePlainQueue< the value type to offer and poll, not null T> Override of the SimpleQueue interface with no throws Exception on poll().
public interface	SimpleQueue< the value type to offer and poll, not null T> A minimalist queue interface without the method bloat of java.util.Collection and java.util.Queue.

Package io.reactivex.internal.fuseable

Interface Summary