Searched refs:retriableStream (Results 1 – 3 of 3) sorted by relevance
174 private final RetriableStream<String> retriableStream = field in RetriableStreamTest201 retriableStream.setAuthority(AUTHORITY); in retry_everythingDrained()202 retriableStream.setCompressor(COMPRESSOR); in retry_everythingDrained()203 retriableStream.setDecompressorRegistry(DECOMPRESSOR_REGISTRY); in retry_everythingDrained()204 retriableStream.setFullStreamDecompression(false); in retry_everythingDrained()205 retriableStream.setFullStreamDecompression(true); in retry_everythingDrained()206 retriableStream.setMaxInboundMessageSize(MAX_INBOUND_MESSAGE_SIZE); in retry_everythingDrained()207 retriableStream.setMessageCompression(true); in retry_everythingDrained()208 retriableStream.setMaxOutboundMessageSize(MAX_OUTBOUND_MESSAGE_SIZE); in retry_everythingDrained()209 retriableStream.setMessageCompression(false); in retry_everythingDrained()[all …]
969 Status add(RetriableStream<?> retriableStream) { in add() argument974 uncommittedRetriableStreams.add(retriableStream); in add()979 void remove(RetriableStream<?> retriableStream) { in remove() argument983 uncommittedRetriableStreams.remove(retriableStream); in remove()
419 RetriableStream<ReqT> retriableStream = ((RetriableStream<ReqT>) stream); in sendMessage() local420 retriableStream.sendMessage(message); in sendMessage()