AbstractSubscription

java.lang.Object
- com.mongodb.async.client.AbstractSubscription<TResult>

All Implemented Interfaces:

Subscription

Direct Known Subclasses:

FlatteningSingleResultCallbackSubscription, MongoIterableSubscription, SingleResultCallbackSubscription
```
abstract class AbstractSubscription<TResult>
extends java.lang.Object
implements Subscription
```

Field Summary

Fields
Modifier and Type	Field and Description
`private boolean`	`isProcessing`
`private boolean`	`isTerminated`
`private boolean`	`isUnsubscribed`
`private Observer<? super TResult>`	`observer`
`private long`	`requested`
`private boolean`	`requestedData`
`private java.util.concurrent.ConcurrentLinkedQueue<TResult>`	`resultsQueue`

Constructor Summary

Constructors
Constructor and Description

AbstractSubscription(Observer<? super TResult> observer)

Constructors
Constructor and Description
`AbstractSubscription(Observer<? super TResult> observer)`

Method Summary

All Methods Instance Methods Abstract Methods Concrete Methods
Modifier and Type	Method and Description
`(package private) void`	`addToQueue(java.util.List<TResult> results)`
`(package private) void`	`addToQueue(TResult result)`
`(package private) abstract boolean`	`checkCompleted()`
`(package private) long`	`getRequested()`
`(package private) boolean`	`isTerminated()`
`boolean`	`isUnsubscribed()` Indicates whether this `Subscription` is currently unsubscribed.
`(package private) void`	`onComplete()`
`(package private) void`	`onError(java.lang.Throwable t)`
`(package private) void`	`onNext(TResult next)`
`(package private) void`	`postTerminate()`
`private void`	`processResultsQueue()`
`void`	`request(long n)` No operation will be sent to MongoDB from the `Observable` until demand is signaled via this method.
`(package private) abstract void`	`requestInitialData()`
`(package private) void`	`requestMoreData()`
`private boolean`	`terminalAction()`
`private void`	`tryProcessResultsQueue()`
`private void`	`tryRequestInitialData()`
`void`	`unsubscribe()` Request the `Observable` to stop sending data and clean up resources.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - observer
```
private final Observer<? super TResult> observer
```
  - requestedData
```
private boolean requestedData
```
  - isProcessing
```
private boolean isProcessing
```
  - requested
```
private long requested
```
  - isUnsubscribed
```
private boolean isUnsubscribed
```
  - isTerminated
```
private boolean isTerminated
```
  - resultsQueue
```
private final java.util.concurrent.ConcurrentLinkedQueue<TResult> resultsQueue
```
- Constructor Detail
  - AbstractSubscription
```
public AbstractSubscription(Observer<? super TResult> observer)
```
- Method Detail
  - unsubscribe
```
public void unsubscribe()
```
    Description copied from interface: Subscription
    
    Request the Observable to stop sending data and clean up resources.
    As this request is asynchronous data may still be sent to meet previously signalled demand after calling cancel.
    
    Specified by:
    
    unsubscribe in interface Subscription
  - isUnsubscribed
```
public boolean isUnsubscribed()
```
    Description copied from interface: Subscription
    
    Indicates whether this Subscription is currently unsubscribed.
    
    Specified by:
    
    isUnsubscribed in interface Subscription
    
    Returns:
    
    true if this Subscription is currently unsubscribed, false otherwise
  - request
```
public void request(long n)
```
    Description copied from interface: Subscription
    
    No operation will be sent to MongoDB from the Observable until demand is signaled via this method.
    It can be called however often and whenever needed, but the outstanding cumulative demand must never exceed Long.MAX_VALUE. An outstanding cumulative demand of Long.MAX_VALUE may be treated by the Observable as "effectively unbounded".
    
    Whatever has been requested might be sent, so only signal demand for what can be safely handled.
    An Observable can send less than is requested if the stream ends but then must emit either Observer.onError(Throwable) or Observer.onComplete().
    
    Specified by:
    
    request in interface Subscription
    
    Parameters:
    
    n - the strictly positive number of elements to requests to the upstream Observable
  - requestInitialData
```
abstract void requestInitialData()
```
  - requestMoreData
```
void requestMoreData()
```
  - postTerminate
```
void postTerminate()
```
  - checkCompleted
```
abstract boolean checkCompleted()
```
  - isTerminated
```
boolean isTerminated()
```
  - getRequested
```
long getRequested()
```
  - addToQueue
```
void addToQueue(TResult result)
```
  - addToQueue
```
void addToQueue(java.util.List<TResult> results)
```
  - onError
```
void onError(java.lang.Throwable t)
```
  - onNext
```
void onNext(TResult next)
```
  - onComplete
```
void onComplete()
```
  - tryRequestInitialData
```
private void tryRequestInitialData()
```
  - tryProcessResultsQueue
```
private void tryProcessResultsQueue()
```
  - processResultsQueue
```
private void processResultsQueue()
```
  - terminalAction
```
private boolean terminalAction()
```

Class AbstractSubscription<TResult>

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

observer

requestedData

isProcessing

requested

isUnsubscribed

isTerminated

resultsQueue

Constructor Detail

AbstractSubscription

Method Detail

unsubscribe

isUnsubscribed

request

requestInitialData

requestMoreData

postTerminate

checkCompleted

isTerminated

getRequested

addToQueue

addToQueue

onError

onNext

onComplete

tryRequestInitialData

tryProcessResultsQueue

processResultsQueue

terminalAction