class FlatteningSingleResultCallbackSubscription<TResult> extends AbstractSubscription<TResult>
Modifier and Type | Field and Description |
---|---|
private Block<SingleResultCallback<java.util.List<TResult>>> |
block |
private boolean |
completed |
Constructor and Description |
---|
FlatteningSingleResultCallbackSubscription(Block<SingleResultCallback<java.util.List<TResult>>> block,
Observer<? super TResult> observer) |
Modifier and Type | Method and Description |
---|---|
(package private) boolean |
checkCompleted() |
(package private) void |
requestInitialData() |
addToQueue, addToQueue, getRequested, isTerminated, isUnsubscribed, onComplete, onError, onNext, postTerminate, request, requestMoreData, unsubscribe
private final Block<SingleResultCallback<java.util.List<TResult>>> block
private boolean completed
FlatteningSingleResultCallbackSubscription(Block<SingleResultCallback<java.util.List<TResult>>> block, Observer<? super TResult> observer)
void requestInitialData()
requestInitialData
in class AbstractSubscription<TResult>
boolean checkCompleted()
checkCompleted
in class AbstractSubscription<TResult>