Searched refs:BlockingResponseStream (Results 1 – 1 of 1) sorted by relevance
157 BlockingResponseStream<RespT> result = new BlockingResponseStream<RespT>(call); in blockingServerStreamingCall()174 BlockingResponseStream<RespT> result = new BlockingResponseStream<RespT>(call, executor); in blockingServerStreamingCall()523 private static final class BlockingResponseStream<T> implements Iterator<T> { class in ClientCalls534 BlockingResponseStream(ClientCall<?, T> call) { in BlockingResponseStream() method in ClientCalls.BlockingResponseStream539 BlockingResponseStream(ClientCall<?, T> call, ThreadlessExecutor threadless) { in BlockingResponseStream() method in ClientCalls.BlockingResponseStream621 buffer.add(BlockingResponseStream.this); in onClose()