Package | Description |
---|---|
com.xjeffrose.xio.client | |
com.xjeffrose.xio.mux |
Modifier and Type | Method and Description |
---|---|
Request |
RequestMuxer.writeExpectResponse(Object payload,
com.google.common.util.concurrent.SettableFuture<UUID> writeFuture,
com.google.common.util.concurrent.SettableFuture<Response> responseFuture) |
Modifier and Type | Method and Description |
---|---|
com.google.common.util.concurrent.ListenableFuture<Response> |
Request.getResponseFuture() |
com.google.common.util.concurrent.SettableFuture<Response> |
Request.getResponsePromise() |
Modifier and Type | Method and Description |
---|---|
void |
Request.registerResponseCallback(com.google.common.util.concurrent.FutureCallback<Response> callback) |
void |
Request.registerResponseCallback(com.google.common.util.concurrent.FutureCallback<Response> callback,
Executor executor) |
Constructor and Description |
---|
Request(UUID id,
com.google.common.util.concurrent.SettableFuture<UUID> writeFuture,
Optional<com.google.common.util.concurrent.SettableFuture<Response>> maybeResponseFuture) |
Request(UUID id,
com.google.common.util.concurrent.SettableFuture<UUID> writeFuture,
com.google.common.util.concurrent.SettableFuture<Response> responseFuture) |
Copyright © 2016. All Rights Reserved.