class SingleResultCallbackSubscription<TResult> extends AbstractSubscription<TResult>
Modifier and Type | Field and Description |
---|---|
private Block<SingleResultCallback<TResult>> |
block |
private boolean |
completed |
Constructor and Description |
---|
SingleResultCallbackSubscription(Block<SingleResultCallback<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<TResult>> block
private boolean completed
SingleResultCallbackSubscription(Block<SingleResultCallback<TResult>> block, Observer<? super TResult> observer)
void requestInitialData()
requestInitialData
in class AbstractSubscription<TResult>
boolean checkCompleted()
checkCompleted
in class AbstractSubscription<TResult>