public class Request extends Object
Modifier and Type | Class and Description |
---|---|
static class |
Request.State |
Constructor and Description |
---|
Request(UUID id,
com.google.common.util.concurrent.SettableFuture<UUID> writeFuture) |
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) |
Modifier and Type | Method and Description |
---|---|
boolean |
expectsResponse() |
com.google.common.util.concurrent.ListenableFuture<Response> |
getResponseFuture() |
com.google.common.util.concurrent.SettableFuture<Response> |
getResponsePromise() |
com.google.common.util.concurrent.ListenableFuture<UUID> |
getWriteFuture() |
com.google.common.util.concurrent.SettableFuture<UUID> |
getWritePromise() |
void |
registerResponseCallback(com.google.common.util.concurrent.FutureCallback<Response> callback) |
void |
registerResponseCallback(com.google.common.util.concurrent.FutureCallback<Response> callback,
Executor executor) |
public Request(UUID id, com.google.common.util.concurrent.SettableFuture<UUID> writeFuture, Optional<com.google.common.util.concurrent.SettableFuture<Response>> maybeResponseFuture)
public Request(UUID id, com.google.common.util.concurrent.SettableFuture<UUID> writeFuture, com.google.common.util.concurrent.SettableFuture<Response> responseFuture)
public boolean expectsResponse()
public void registerResponseCallback(com.google.common.util.concurrent.FutureCallback<Response> callback)
public void registerResponseCallback(com.google.common.util.concurrent.FutureCallback<Response> callback, Executor executor)
public com.google.common.util.concurrent.ListenableFuture<UUID> getWriteFuture()
public com.google.common.util.concurrent.SettableFuture<UUID> getWritePromise()
public com.google.common.util.concurrent.ListenableFuture<Response> getResponseFuture()
public com.google.common.util.concurrent.SettableFuture<Response> getResponsePromise()
Copyright © 2016. All Rights Reserved.