com.mongodb.async.client

Class FlatteningSingleResultCallbackSubscription<TResult>

java.lang.Object

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

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

All Implemented Interfaces:

Subscription

class FlatteningSingleResultCallbackSubscription<TResult>
extends AbstractSubscription<TResult>

Field Summary

Fields

Modifier and Type	Field and Description
private Block<SingleResultCallback<java.util.List<TResult>>>	block
private boolean	completed

Constructor Summary

Constructors

Constructor and Description
FlatteningSingleResultCallbackSubscription(Block<SingleResultCallback<java.util.List<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<java.util.List<TResult>>> block

completed

private boolean completed

Constructor Detail

FlatteningSingleResultCallbackSubscription

public FlatteningSingleResultCallbackSubscription(Block<SingleResultCallback<java.util.List<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>