Searched refs:futureReply (Results 1 – 1 of 1) sorted by relevance
174 private var futureReply: CompletableFuture<ByteArray>? = null variable193 futureReply!!.complete(recvbuf.sliceArray(8..<length)) in handlePacket()212 futureReply = CompletableFuture<ByteArray>() in sendPing()217 return futureReply!!.get(TIMEOUT_MS, TimeUnit.MILLISECONDS) in expectPingReply()222 futureReply!!.get(TIMEOUT_MS, TimeUnit.MILLISECONDS) in expectPingDropped()