com.mongodb.async.client

Class SingleResultCallbackSubscription<TResult>

java.lang.Object

com.mongodb.async.client.AbstractSubscription<TResult>

com.mongodb.async.client.SingleResultCallbackSubscription<TResult>

All Implemented Interfaces:

Subscription

class SingleResultCallbackSubscription<TResult>
extends AbstractSubscription<TResult>

Field Summary

Fields

Modifier and Type	Field and Description
private Block<SingleResultCallback<TResult>>	block
private boolean	completed

Constructor Summary

Constructors

Constructor and Description
SingleResultCallbackSubscription(Block<SingleResultCallback<TResult>> block, Observer<? super TResult> observer)

Method Summary

Modifier and Type	Method and Description
(package private) boolean	checkCompleted()
(package private) void	requestInitialData()

Methods inherited from class com.mongodb.async.client.AbstractSubscription

addToQueue, addToQueue, getRequested, isTerminated, isUnsubscribed, onComplete, onError, onNext, postTerminate, request, requestMoreData, unsubscribe

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

block

private final Block<SingleResultCallback<TResult>> block

completed

private boolean completed

Constructor Detail

SingleResultCallbackSubscription

public SingleResultCallbackSubscription(Block<SingleResultCallback<TResult>> block,
                                        Observer<? super TResult> observer)

Method Detail

requestInitialData

void requestInitialData()

Specified by:

requestInitialData in class AbstractSubscription<TResult>

checkCompleted

boolean checkCompleted()

Specified by:

checkCompleted in class AbstractSubscription<TResult>