Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 104 of 104 for CountDownLatch (0.3 sec)

  1. docs/smb3-features/06-witness-protocol-design.md

    }
    
    private static class TestWitnessListener implements WitnessClient.WitnessNotificationListener {
        private volatile boolean notificationReceived = false;
        private final CountDownLatch latch = new CountDownLatch(1);
        
        @Override
        public void onWitnessNotification(WitnessNotification notification) {
            notificationReceived = true;
            latch.countDown();
        }
        
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 42K bytes
    - Viewed (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.kt

    import java.net.InetAddress
    import java.net.InetSocketAddress
    import java.net.Proxy
    import java.net.UnknownHostException
    import java.time.Duration
    import java.util.Arrays
    import java.util.concurrent.CountDownLatch
    import java.util.concurrent.TimeUnit
    import kotlin.test.assertFailsWith
    import mockwebserver3.MockResponse
    import mockwebserver3.MockWebServer
    import mockwebserver3.SocketEffect.CloseSocket
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Nov 05 18:28:35 UTC 2025
    - 70.5K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt

    import java.net.UnknownHostException
    import java.net.UnknownServiceException
    import java.time.Duration
    import java.util.Arrays
    import java.util.concurrent.BlockingQueue
    import java.util.concurrent.CountDownLatch
    import java.util.concurrent.Executors
    import java.util.concurrent.SynchronousQueue
    import java.util.concurrent.TimeUnit
    import java.util.concurrent.atomic.AtomicBoolean
    import java.util.concurrent.atomic.AtomicInteger
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Nov 04 19:13:52 UTC 2025
    - 147.4K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt

    import assertk.assertions.isLessThan
    import assertk.assertions.isNull
    import assertk.assertions.isTrue
    import java.io.EOFException
    import java.io.IOException
    import java.io.InterruptedIOException
    import java.util.concurrent.CountDownLatch
    import java.util.concurrent.TimeUnit
    import java.util.concurrent.atomic.AtomicInteger
    import kotlin.test.assertFailsWith
    import okhttp3.Headers
    import okhttp3.Headers.Companion.headersOf
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 75.5K bytes
    - Viewed (0)
Back to top