Top Description Methods
io.reactivex.internal.fuseable

public Interface ScalarCallable<T>

extends Callable<T>
Known Direct Implementers
io.reactivex.internal.operators.flowable.FlowableJust, io.reactivex.internal.operators.flowable.FlowableEmpty, io.reactivex.internal.operators.maybe.MaybeJust, io.reactivex.internal.operators.maybe.MaybeEmpty, io.reactivex.internal.operators.observable.ObservableEmpty, io.reactivex.internal.operators.observable.ObservableJust
Type Parameters
<T>
the scalar value type held by the implementing reactive type
Imports
java.util.concurrent.Callable
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.

Implementors of call() should not throw any exception.

Design Note

the interface extends Callable because if a scalar is safe to extract during assembly time, it is also safe to extract at subscription time or later. This allows optimizations to deal with such single-element sources uniformly.

Method Summary

Modifier and TypeMethod and Description
public T
call()

Redeclares java.util.concurrent.Callable.call.

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

Method Detail

callback to summary
public T call()

Redeclares 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