Package | Description |
---|---|
com.allanbank.mongodb |
Provides a Java driver for the MongoDB document store that allows asynchronous invocation of requests.
|
com.allanbank.mongodb.client |
Provides implementations of the main client interfaces and classes to translate the
Reply (s) from the server. |
com.allanbank.mongodb.client.callback |
Provides implementation for various transformations, implemented in the form of
Callback s, that are used by the driver. |
Modifier and Type | Method and Description |
---|---|
MongoCursorControl |
MongoClient.restart(StreamCallback<Document> results,
DocumentAssignable cursorDocument)
Restarts a document stream from a cursor that was previously saved.
|
MongoCursorControl |
AsyncMongoCollection.stream(StreamCallback<Document> results,
Aggregate.Builder aggregation)
Performs an aggregation and streams them to the provided callback one at
a time.
|
MongoCursorControl |
AsyncMongoCollection.stream(StreamCallback<Document> results,
Aggregate aggregation)
Performs an aggregation and streams them to the provided callback one at
a time.
|
MongoCursorControl |
AsyncMongoCollection.stream(StreamCallback<Document> results,
Find.Builder query)
Finds the set of documents matching the query in the collection and
streams them to the provided callback one at a time.
|
MongoCursorControl |
AsyncMongoCollection.stream(StreamCallback<Document> results,
Find query)
Finds the set of documents matching the query in the collection and
streams them to the provided callback one at a time.
|
MongoCursorControl |
AsyncMongoCollection.streamingFind(StreamCallback<Document> results,
DocumentAssignable query)
Finds the set of documents matching the query document in the collection
and streams them to the provided callback one at a time.
|
MongoCursorControl |
AsyncMongoCollection.streamingFind(StreamCallback<Document> results,
Find.Builder query)
Deprecated.
Use the
AsyncMongoCollection.stream(StreamCallback, Find.Builder) method
instead. This method will be removed after the 1.4.0 release. |
MongoCursorControl |
AsyncMongoCollection.streamingFind(StreamCallback<Document> results,
Find query)
Deprecated.
Use the
AsyncMongoCollection.stream(StreamCallback, Find) method instead.
This method will be removed after the 1.4.0 release. |
Modifier and Type | Class and Description |
---|---|
class |
LambdaCallbackAdapter<V>
|
Modifier and Type | Method and Description |
---|---|
MongoCursorControl |
SerialClientImpl.restart(StreamCallback<Document> results,
DocumentAssignable cursorDocument)
Restarts a document stream from a cursor that was previously saved.
|
MongoCursorControl |
MongoClientImpl.restart(StreamCallback<Document> results,
DocumentAssignable cursorDocument)
Restarts a document stream from a cursor that was previously saved.
|
MongoCursorControl |
ClientImpl.restart(StreamCallback<Document> results,
DocumentAssignable cursorDocument)
Restarts a document stream from a cursor that was previously saved.
|
MongoCursorControl |
Client.restart(StreamCallback<Document> results,
DocumentAssignable cursorDocument)
Restarts a document stream from a cursor that was previously saved.
|
MongoCursorControl |
AbstractAsyncMongoCollection.stream(StreamCallback<Document> results,
Aggregate.Builder aggregation)
Performs an aggregation and streams them to the provided callback one at
a time.
|
MongoCursorControl |
AbstractMongoOperations.stream(StreamCallback<Document> results,
Aggregate aggregation)
Constructs a
aggregate command and sends it to the server via the
Client . |
MongoCursorControl |
AbstractAsyncMongoCollection.stream(StreamCallback<Document> results,
Find.Builder query)
Finds the set of documents matching the query in the collection and
streams them to the provided callback one at a time.
|
MongoCursorControl |
AbstractMongoOperations.stream(StreamCallback<Document> results,
Find query)
|
MongoCursorControl |
AbstractAsyncMongoCollection.streamingFind(StreamCallback<Document> results,
DocumentAssignable query)
Finds the set of documents matching the query document in the collection
and streams them to the provided callback one at a time.
|
MongoCursorControl |
AbstractAsyncMongoCollection.streamingFind(StreamCallback<Document> results,
Find.Builder query)
Deprecated.
|
MongoCursorControl |
AbstractAsyncMongoCollection.streamingFind(StreamCallback<Document> results,
Find query)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
LegacyStreamCallbackAdapter
Deprecated.
Deprecated to ensure this class is removed with the
AsyncMongoCollection.streamingFind(Callback, com.allanbank.mongodb.bson.DocumentAssignable)
and
AsyncMongoCollection.streamingFind(Callback, com.allanbank.mongodb.builder.Find)
methods. |
Constructor and Description |
---|
CursorStreamingCallback(Client client,
CursorableMessage originalMessage,
boolean command,
StreamCallback<Document> results)
Create a new CursorCallback.
|
CursorStreamingCallback(Client client,
Document cursorDocument,
StreamCallback<Document> results)
Create a new CursorCallback from a cursor document.
|
Copyright © 2011–2014 Allanbank Consulting, Inc.. All rights reserved.