Searched refs:delayOrExecute (Results 1 – 2 of 2) sorted by relevance
64 delayOrExecute(new Runnable() { in setMaxInboundMessageSize()78 delayOrExecute(new Runnable() { in setMaxOutboundMessageSize()89 delayOrExecute(new Runnable() { in setDeadline()159 private void delayOrExecute(Runnable runnable) { in delayOrExecute() method in DelayedStream173 delayOrExecute(new Runnable() { in setAuthority()205 delayOrExecute(new Runnable() { in start()226 delayOrExecute(new Runnable() { in writeMessage()240 delayOrExecute(new Runnable() { in flush()267 delayOrExecute(new Runnable() { in cancel()283 delayOrExecute(new Runnable() { in halfClose()[all …]
310 private void delayOrExecute(BufferEntry bufferEntry) { in delayOrExecute() method in RetriableStream347 delayOrExecute(new SendMessageEntry()); in sendMessage()365 delayOrExecute(new RequestEntry()); in request()383 delayOrExecute(new FlushEntry()); in flush()405 delayOrExecute(new CompressorEntry()); in setCompressor()417 delayOrExecute(new FullStreamDecompressionEntry()); in setFullStreamDecompression()429 delayOrExecute(new MessageCompressionEntry()); in setMessageCompression()441 delayOrExecute(new HalfCloseEntry()); in halfClose()453 delayOrExecute(new AuthorityEntry()); in setAuthority()465 delayOrExecute(new DecompressorRegistryEntry()); in setDecompressorRegistry()[all …]