public interface InboundDataClient
Modifier and Type | Method and Description |
---|---|
void |
awaitCompletion()
Block until the client has completed reading from the inbound stream.
|
void |
cancel()
Cancels the client, causing it to drop any future inbound data.
|
void |
complete()
Mark the client as completed.
|
void |
fail(java.lang.Throwable t)
Mark the client as completed with an exception.
|
boolean |
isDone()
Returns true if the client is done, either via completing successfully or by being cancelled.
|
void awaitCompletion() throws java.lang.InterruptedException, java.lang.Exception
java.lang.InterruptedException
- if the client is interrupted before completing.java.util.concurrent.CancellationException
- if the client is cancelled before completing.java.lang.Exception
- if the client throws an exception while awaiting completion.boolean isDone()
void cancel()
void complete()
void fail(java.lang.Throwable t)
t
- the throwable that caused this client to fail