public class AsyncSingleConnectionReadBinding extends AbstractReferenceCounted implements AsyncReadBinding
| Modifier and Type | Class and Description |
|---|---|
private class |
AsyncSingleConnectionReadBinding.AsyncSingleConnectionSource |
| Modifier and Type | Field and Description |
|---|---|
private AsyncConnection |
connection |
private ReadPreference |
readPreference |
private ServerDescription |
serverDescription |
| Constructor and Description |
|---|
AsyncSingleConnectionReadBinding(ReadPreference readPreference,
ServerDescription serverDescription,
AsyncConnection connection)
Construct an instance.
|
| Modifier and Type | Method and Description |
|---|---|
void |
getReadConnectionSource(SingleResultCallback<AsyncConnectionSource> callback)
Returns a connection source to a server that satisfies the specified read preference.
|
ReadPreference |
getReadPreference()
The read preference that all connection sources returned by this instance will satisfy.
|
void |
release()
Release a reference to this object.
|
AsyncReadBinding |
retain()
Retain an additional reference to this object.
|
getCountclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetCountprivate final ReadPreference readPreference
private final ServerDescription serverDescription
private final AsyncConnection connection
public AsyncSingleConnectionReadBinding(ReadPreference readPreference, ServerDescription serverDescription, AsyncConnection connection)
readPreference - the read preferenced of this bindingserverDescription - the description of the serverconnection - the connection to bind to.public ReadPreference getReadPreference()
AsyncReadBindinggetReadPreference in interface AsyncReadBindingpublic void getReadConnectionSource(SingleResultCallback<AsyncConnectionSource> callback)
AsyncReadBindinggetReadConnectionSource in interface AsyncReadBindingcallback - the to be passed the connection sourcepublic AsyncReadBinding retain()
ReferenceCountedretain in interface AsyncReadBindingretain in interface ReferenceCountedretain in class AbstractReferenceCountedpublic void release()
ReferenceCountedrelease in interface ReferenceCountedrelease in class AbstractReferenceCounted