Class BidiStreamingCallable<RequestT,ResponseT> (2.11.0)

A BidiStreamingCallable is an immutable object which is capable of making RPC calls to bidirectional streaming API methods. Not all transports support streaming.

It is considered advanced usage for a user to create a BidiStreamingCallable themselves. This class is intended to be created by a generated client class, and configured by instances of StreamingCallSettings.Builder which are exposed through the client settings class.

Deprecated. Please use #splitCall(ResponseObserver) instead.

Conduct a bidirectional streaming call

Deprecated. Please use #splitCall(ResponseObserver, ApiCallContext) instead.

Conduct a bidirectional streaming call with the given ApiCallContext.

Send requests and iterate over server responses.

This returns a live stream that must either be fully consumed or cancelled. Example usage:

 BidiStream

Send requests and iterate over server responses.

This returns a live stream that must either be fully consumed or cancelled.

Listens to server responses and send requests when the network is free. Example usage:

 final Iterator<Integer> sourceDataIterator = intCollection.iterator();
 BidiStreamObserver

Listens to server responses and send requests when the network is free.

The "base" method from which other forms of calls are derived. Most users will not need to call this method directly.

However, it is public, since library authors might want to call this method in adaptor classes.

Send requests to the server and listens to responses.

Example usage:

 ResponseObserver<String> responseObserver = new ResponseObserver<String>() {
   public void onStart(StreamController controller) {
     // no-op
   }

  public void onResponse(String response) {
    System.out.println(response);
  }

  public void onComplete() {
    System.out.println("done!");
  }

  public void onError(Throwable t) {
    System.out.println("error: " + t);
  }
 };

 ClientStream<Integer> clientStream = bidiStreamingCallable.splitCall(responseObserver);
 clientStream.send(42);
 clientStream.send(43);
 clientStream.close();
 

Send requests to the server and listens to responses.

Returns a new BidiStreamingCallable with an ApiCallContext that is used as a default when none is supplied in individual calls.