Searched defs:StreamResponseFuture (Results 1 – 1 of 1) sorted by relevance
137 static class StreamResponseFuture<RequestT extends MessageLite, ResponseT extends MessageLite> class in FutureCall148 private StreamResponseFuture(Endpoint endpoint, PendingRpc rpc, Consumer<ResponseT> onNext) { in StreamResponseFuture() method in FutureCall.StreamResponseFuture