Class BidiStreamingCallable<RequestT,ResponseT> (2.72.1)

publicabstractclass BidiStreamingCallable<RequestT,ResponseT>

protectedBidiStreamingCallable()

publicApiStreamObserver<RequestT>bidiStreamingCall(ApiStreamObserver<ResponseT>responseObserver)

publicApiStreamObserver<RequestT>bidiStreamingCall(ApiStreamObserver<ResponseT>responseObserver,ApiCallContextcontext)

publicBidiStream<RequestT,ResponseT>call()

BidiStream<String,String>stream=bidiStreamingCallable.call()
for(Strings:stream){
if("needle".equals(s)){
// Cancelling the stream will cause hasNext() to return false on the next iteration,
// naturally breaking the loop.
stream.cancel();
}
stream.send(s);
}

publicBidiStream<RequestT,ResponseT>call(ApiCallContextcontext)

publicvoidcall(BidiStreamObserver<RequestT,ResponseT>bidiObserver)

finalIterator<Integer>sourceDataIterator=intCollection.iterator();
BidiStreamObserver<Integer,String>bidiStreamObserver=newBidiStreamObserver<Integer,String>(){
publicvoidonStart(StreamControllercontroller){
// no-op
}
publicvoidonResponse(Stringresponse){
System.out.println(response);
}
publicvoidonComplete(){
System.out.println("done!");
}
publicvoidonError(Throwablet){
System.out.println("error: "+t);
}
publicvoidonReady(ClientStream<Integer>stream){
while(sourceDataIterator.hasNext()){
if(stream.isReady()){
stream.send(sourceDataIterator.next());
}else{
// It's OK we haven't consumed the whole iterator;
// onReady will be called again when the network becomes free.
return;
}
}
// We ran out of things to send.
stream.close();
}
};
bidiStreamingCallable.call(bidiStreamObserver);

publicvoidcall(BidiStreamObserver<RequestT,ResponseT>bidiObserver,ApiCallContextcontext)

publicabstractClientStream<RequestT>internalCall(ResponseObserver<ResponseT>responseObserver,ClientStreamReadyObserver<RequestT>onReady,ApiCallContextcontext)

publicClientStream<RequestT>splitCall(ResponseObserver<ResponseT>responseObserver)

ResponseObserver<String>responseObserver=newResponseObserver<String>(){
publicvoidonStart(StreamControllercontroller){
// no-op
}
publicvoidonResponse(Stringresponse){
System.out.println(response);
}
publicvoidonComplete(){
System.out.println("done!");
}
publicvoidonError(Throwablet){
System.out.println("error: "+t);
}
};
ClientStream<Integer>clientStream=bidiStreamingCallable.splitCall(responseObserver);
clientStream.send(42);
clientStream.send(43);
clientStream.close();

publicClientStream<RequestT>splitCall(ResponseObserver<ResponseT>responseObserver,ApiCallContextcontext)

publicBidiStreamingCallable<RequestT,ResponseT>withDefaultCallContext(ApiCallContextdefaultCallContext)