Searched defs:channelPromise (Results 1 – 8 of 8) sorted by relevance
177 Promise<Channel> channelPromise = new DefaultPromise<>(loopGroup.next()); in availableStream0_reusableShouldBeFalse() local188 Promise<Channel> channelPromise = new DefaultPromise<>(loopGroup.next()); in acquireClaimedConnection_channelClosed_shouldThrowIOException() local203 Promise<Channel> channelPromise = new DefaultPromise<>(loopGroup.next()); in closeChildChannels_shouldDeliverException() local
159 Promise<Channel> channelPromise = new DefaultPromise<>(loopGroup.next()); in acquire_shouldAcquireAgainIfExistingNotReusable() local181 Promise<Channel> channelPromise = new DefaultPromise<>(loopGroup.next()); in interruptDuringClosePreservesFlag() local224 Promise<Channel> channelPromise = new DefaultPromise<>(loopGroup.next()); in acquire_shouldExpandConnectionWindowSizeProportionally() local
218 Promise<Channel> channelPromise = eventLoop.newPromise(); in createSuccessfulAcquire() local
114 private CompletableFuture<Void> createExecutionFuture(Promise<Channel> channelPromise) { in createExecutionFuture()
META-INF/MANIFEST.MF META-INF/ META-INF/native/ io/ ...
META-INF/ META-INF/MANIFEST.MF io/ io/grpc/ io/ ...
META-INF/ META-INF/MANIFEST.MF build-data.properties com/ com ...
FileMd5$FileChecksum$1.class FileMd5.java package FileMd5$FileChecksum$1 extends com. ...