Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for countdown (0.06 sec)

  1. android/guava-tests/test/com/google/common/cache/CacheLoadingTest.java

            cache.getUnchecked(getKey);
            getFinishedSignal.countDown();
          }
        }.start();
        new Thread() {
          @Override
          public void run() {
            cache.refresh(refreshKey);
            getFinishedSignal.countDown();
          }
        }.start();
    
        // let computation complete
        letGetFinishSignal.countDown();
        getFinishedSignal.await();
        checkNothingLogged();
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 86.3K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt

              response: Response,
            ) {
              bodies.add(response.body.string())
              latch.countDown()
            }
    
            override fun onFailure(
              call: Call,
              e: IOException,
            ) {
              errors.add(e)
              latch.countDown()
            }
          }
        client.newCall(Request.Builder().url(server.url("/")).build()).enqueue(
          callback,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 75.3K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/EventListenerTest.kt

            override fun onFailure(
              call: Call,
              e: IOException,
            ) {
              completionLatch.countDown()
            }
    
            override fun onResponse(
              call: Call,
              response: Response,
            ) {
              response.close()
              completionLatch.countDown()
            }
          }
        call.enqueue(callback)
        completionLatch.await()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 56.9K bytes
    - Viewed (2)
  4. okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt

              connection: Http2Connection,
              settings: Settings,
            ) {
              maxConcurrentStreams.set(settings.getMaxConcurrentStreams())
              maxConcurrentStreamsUpdated.countDown()
            }
          }
        val connection = connect(peer, IGNORE, listener)
        connection.withLock {
          assertThat(connection.peerSettings.getMaxConcurrentStreams()).isEqualTo(10)
        }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 75.4K bytes
    - Viewed (0)
Back to top