- 2.70.0 (latest)
- 2.69.0
- 2.68.2
- 2.67.0
- 2.66.0
- 2.65.0
- 2.63.1
- 2.62.0
- 2.61.0
- 2.60.0
- 2.59.1
- 2.58.0
- 2.57.0
- 2.55.0
- 2.54.1
- 2.53.0
- 2.52.0
- 2.51.0
- 2.50.0
- 2.49.0
- 2.48.1
- 2.47.0
- 2.46.1
- 2.45.0
- 2.43.0
- 2.42.0
- 2.41.0
- 2.39.0
- 2.38.0
- 2.37.0
- 2.36.0
- 2.35.0
- 2.34.1
- 2.33.0
- 2.32.1
- 2.31.1
- 2.30.1
- 2.24.0
- 2.23.3
- 2.22.0
- 2.21.0
- 2.20.1
- 2.19.6
- 2.18.7
- 2.17.0
- 2.16.0
- 2.15.0
- 2.14.0
- 2.13.0
- 2.12.2
- 2.11.0
- 2.10.0
- 2.9.0
- 2.8.1
- 2.7.1
public
interface
ClientStream<RequestT>
A wrapper used to send requests to the server.
After sending requests, users must either call #closeSend() or #closeSendWithError(Throwable) on the stream. The error, if any, will be propagated to the server.
Example usage:
ClientStream<String>
stream
=
...;
List<String>
lines
=
getLinesFromFile
();
for
(
String
line
:
lines
)
{
stream
.
send
(
line
);
}
stream
.
closeSend
();
Type Parameter
RequestT
Methods
closeSend()
public
abstract
void
closeSend
()
Closes the stream. If called, this must be the last call on this ClientStream
.
Note that if close()
itself throws, a further call to closeSendWithError
is
not allowed.
closeSendWithError(Throwable t)
public
abstract
void
closeSendWithError
(
Throwable
t
)
Closes the stream with an error. If called, this must be the last call on this ClientStream
.
isSendReady()
public
abstract
boolean
isSendReady
()
Reports whether a new request can be sent without excessive buffering.
This is only an optimization hint to the user. It is correct, if suboptimal, to call send
if isSendReady
returns false.
send(RequestT request)
public
abstract
void
send
(
RequestT
request
)
Sends a request to the server. It is an error to call this if the stream is already closed.
request
RequestT