- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for waitDone (0.21 sec)
-
src/net/http/transport_dial_test.go
dt := newTransportDialTester(t, http1Mode) // First request creates a new connection. rt1 := dt.roundTrip() c1 := dt.wantDial() c1.finish(nil) rt1.wantDone(c1) rt1.finish() // Second request reuses the first connection. rt2 := dt.roundTrip() rt2.wantDone(c1) rt2.finish() } func TestTransportPoolConnCannotReuseConnectionInUse(t *testing.T) { dt := newTransportDialTester(t, http1Mode)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 17 21:11:57 UTC 2024 - 6.3K bytes - Viewed (0) -
guava-testlib/test/com/google/common/testing/GcFinalizationTest.java
new Object() { @Override protected void finalize() { future.set(null); } }; x = null; // Hint to the JIT that x is unreachable GcFinalization.awaitDone(future); assertTrue(future.isDone()); assertFalse(future.isCancelled()); } public void testAwaitDone_Future_Cancel() { final SettableFuture<@Nullable Void> future = SettableFuture.create();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 7.4K bytes - Viewed (0) -
android/guava-testlib/test/com/google/common/testing/GcFinalizationTest.java
new Object() { @Override protected void finalize() { future.set(null); } }; x = null; // Hint to the JIT that x is unreachable GcFinalization.awaitDone(future); assertTrue(future.isDone()); assertFalse(future.isCancelled()); } public void testAwaitDone_Future_Cancel() { final SettableFuture<@Nullable Void> future = SettableFuture.create();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 19:21:11 UTC 2024 - 7.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/FileBackedOutputStreamAndroidIncompatibleTest.java
assertTrue(file.exists()); out.close(); // Make sure that finalize deletes the file out = null; // times out and throws RuntimeException on failure GcFinalization.awaitDone( new GcFinalization.FinalizationPredicate() { @Override public boolean isDone() { return !file.exists(); } }); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Jun 08 21:20:23 UTC 2023 - 1.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/base/FinalizableReferenceQueueTest.java
frq = null; } public void testFinalizeReferentCalled() { final MockReference reference = new MockReference(frq = new FinalizableReferenceQueue()); GcFinalization.awaitDone( new GcFinalization.FinalizationPredicate() { @Override public boolean isDone() { return reference.finalizeReferentCalled; } }); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 19:21:11 UTC 2024 - 4.8K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
} /** Constructs a listenable future with a value available after the latch has counted down. */ protected abstract <V> ListenableFuture<V> createListenableFuture( V value, @Nullable Exception except, CountDownLatch waitOn); /** Tests that the {@link Future#get()} method blocks until a value is available. */ public void testGetBlocksUntilValueAvailable() throws Throwable { assertFalse(future.isDone());
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 18:30:30 UTC 2023 - 6K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
} /** Constructs a listenable future with a value available after the latch has counted down. */ protected abstract <V> ListenableFuture<V> createListenableFuture( V value, @Nullable Exception except, CountDownLatch waitOn); /** Tests that the {@link Future#get()} method blocks until a value is available. */ public void testGetBlocksUntilValueAvailable() throws Throwable { assertFalse(future.isDone());
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 18:30:30 UTC 2023 - 6K bytes - Viewed (0)