Searched refs:closedFuture (Results 1 – 2 of 2) sorted by relevance
110 final SettableFuture<Status> closedFuture = SettableFuture.create(); in queuedBytesInDeframerShouldNotBlockComplete() local117 closedFuture.set(status); in queuedBytesInDeframerShouldNotBlockComplete()126 assertEquals(Status.OK, closedFuture.get(TIMEOUT_MS, TimeUnit.MILLISECONDS)); in queuedBytesInDeframerShouldNotBlockComplete()131 final SettableFuture<Status> closedFuture = SettableFuture.create(); in queuedBytesInDeframerShouldNotBlockTransportReportStatus() local138 closedFuture.set(status); in queuedBytesInDeframerShouldNotBlockTransportReportStatus()146 assertEquals(Status.CANCELLED, closedFuture.get(TIMEOUT_MS, TimeUnit.MILLISECONDS)); in queuedBytesInDeframerShouldNotBlockTransportReportStatus()151 final SettableFuture<Status> closedFuture = SettableFuture.create(); in partialMessageAtEndOfStreamShouldFail() local158 closedFuture.set(status); in partialMessageAtEndOfStreamShouldFail()166 Status status = closedFuture.get(TIMEOUT_MS, TimeUnit.MILLISECONDS); in partialMessageAtEndOfStreamShouldFail()
676 listener.closedFuture.get(10, TimeUnit.SECONDS); in waitForClose()681 final SettableFuture<Void> closedFuture = SettableFuture.create(); field in NettyClientTransportTest.TestClientStreamListener696 closedFuture.set(null); in closed()699 closedFuture.setException(e); in closed()