Searched refs:connectFuture (Results 1 – 2 of 2) sorted by relevance
66 Future<Void> connectFuture = asc.connect(remoteAddress); in test_connect() local67 connectFuture.get(1000, TimeUnit.MILLISECONDS); in test_connect()275 Future<Void> connectFuture = asc.connect(ss.getLocalSocketAddress()); in test_futureReadWrite() local276 connectFuture.get(1000, TimeUnit.MILLISECONDS); in test_futureReadWrite()278 assertTrue(connectFuture.isDone()); in test_futureReadWrite()784 Future<Void> connectFuture = asc.connect(ss.getLocalSocketAddress()); in test_shutdown() local785 connectFuture.get(1000, TimeUnit.MILLISECONDS); in test_shutdown()
70 private PendingFuture<Void,Object> connectFuture; field in UnixAsynchronousSocketChannelImpl297 PendingFuture<Void,Object> future = connectFuture; in finishConnect()357 this.connectFuture = (PendingFuture<Void,Object>)result; in implConnect()