summaryrefslogtreecommitdiff
path: root/lib/java/src/main/java/org/apache/thrift/async/TAsyncClient.java
diff options
context:
space:
mode:
Diffstat (limited to 'lib/java/src/main/java/org/apache/thrift/async/TAsyncClient.java')
-rw-r--r--lib/java/src/main/java/org/apache/thrift/async/TAsyncClient.java23
1 files changed, 16 insertions, 7 deletions
diff --git a/lib/java/src/main/java/org/apache/thrift/async/TAsyncClient.java b/lib/java/src/main/java/org/apache/thrift/async/TAsyncClient.java
index 8ba135642..06d6f6382 100644
--- a/lib/java/src/main/java/org/apache/thrift/async/TAsyncClient.java
+++ b/lib/java/src/main/java/org/apache/thrift/async/TAsyncClient.java
@@ -29,11 +29,18 @@ public abstract class TAsyncClient {
private Exception ___error;
private long ___timeout;
- public TAsyncClient(TProtocolFactory protocolFactory, TAsyncClientManager manager, TNonblockingTransport transport) {
+ public TAsyncClient(
+ TProtocolFactory protocolFactory,
+ TAsyncClientManager manager,
+ TNonblockingTransport transport) {
this(protocolFactory, manager, transport, 0);
}
- public TAsyncClient(TProtocolFactory protocolFactory, TAsyncClientManager manager, TNonblockingTransport transport, long timeout) {
+ public TAsyncClient(
+ TProtocolFactory protocolFactory,
+ TAsyncClientManager manager,
+ TNonblockingTransport transport,
+ long timeout) {
this.___protocolFactory = protocolFactory;
this.___manager = manager;
this.___transport = transport;
@@ -58,6 +65,7 @@ public abstract class TAsyncClient {
/**
* Is the client in an error state?
+ *
* @return If client in an error state?
*/
public boolean hasError() {
@@ -66,7 +74,9 @@ public abstract class TAsyncClient {
/**
* Get the client's error - returns null if no error
- * @return Get the client's error. <p> returns null if no error
+ *
+ * @return Get the client's error.
+ * <p>returns null if no error
*/
public Exception getError() {
return ___error;
@@ -75,7 +85,8 @@ public abstract class TAsyncClient {
protected void checkReady() {
// Ensure we are not currently executing a method
if (___currentMethod != null) {
- throw new IllegalStateException("Client is currently executing another method: " + ___currentMethod.getClass().getName());
+ throw new IllegalStateException(
+ "Client is currently executing another method: " + ___currentMethod.getClass().getName());
}
// Ensure we're not in an error state
@@ -84,9 +95,7 @@ public abstract class TAsyncClient {
}
}
- /**
- * Called by delegate method when finished
- */
+ /** Called by delegate method when finished */
protected void onComplete() {
___currentMethod = null;
}