Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for runNext (0.11 sec)

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

        private final Deque<Runnable> tasks = Queues.newArrayDeque();
    
        @Override
        public void execute(Runnable task) {
          tasks.add(task);
        }
    
        private void runNext() {
          tasks.removeFirst().run();
        }
      }
    
      public void testAsyncReload() throws Exception {
        final AtomicInteger loadCount = new AtomicInteger();
        final AtomicInteger reloadCount = new AtomicInteger();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  2. okhttp-coroutines/src/test/kotlin/okhttp3/coroutines/ExecuteAsyncTest.kt

      }
    
      @Test
      fun suspendCall() {
        runTest {
          server.enqueue(MockResponse(body = "abc"))
    
          val call = client.newCall(request)
    
          call.executeAsync().use {
            withContext(Dispatchers.IO) {
              assertThat(it.body.string()).isEqualTo("abc")
            }
          }
        }
      }
    
      @Test
      fun timeoutCall() {
        runTest {
          server.enqueue(
            MockResponse.Builder()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 18 01:24:38 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/AutobahnTester.kt

      fun run() {
        try {
          val count = getTestCount()
          println("Test count: $count")
          for (number in 1..count) {
            runTest(number, count)
          }
          updateReports()
        } finally {
          client.dispatcher.executorService.shutdown()
        }
      }
    
      private fun runTest(
        number: Long,
        count: Long,
      ) {
        val latch = CountDownLatch(1)
        val startNanos = AtomicLong()
        newWebSocket(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  4. guava-testlib/test/com/google/common/testing/TestLogHandlerTest.java

        for (LogRecord unused : handler.getStoredLogRecords()) {
          ExampleClassUnderTest.foo();
        }
      }
    
      @Override
      public final void runBare() throws Throwable {
        try {
          setUp();
          runTest();
        } finally {
          tearDown();
        }
      }
    
      @Override
      protected void tearDown() {
        stack.runTearDown();
      }
    
      static final Exception EXCEPTION = new Exception();
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 2.8K bytes
    - Viewed (0)
  5. guava-testlib/test/com/google/common/testing/TearDownStackTest.java

        }
    
        assertEquals(true, tearDownOne.ran);
        assertEquals(true, tearDownTwo.ran);
      }
    
      @Override
      public final void runBare() throws Throwable {
        try {
          setUp();
          runTest();
        } finally {
          tearDown();
        }
      }
    
      @Override
      protected void tearDown() {
        tearDownStack.runTearDown();
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 21 10:19:29 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  6. android/guava-testlib/test/com/google/common/testing/TearDownStackTest.java

        }
    
        assertEquals(true, tearDownOne.ran);
        assertEquals(true, tearDownTwo.ran);
      }
    
      @Override
      public final void runBare() throws Throwable {
        try {
          setUp();
          runTest();
        } finally {
          tearDown();
        }
      }
    
      @Override
      protected void tearDown() {
        tearDownStack.runTearDown();
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 21 10:19:29 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  7. android/guava-testlib/test/com/google/common/testing/TestLogHandlerTest.java

        for (LogRecord unused : handler.getStoredLogRecords()) {
          ExampleClassUnderTest.foo();
        }
      }
    
      @Override
      public final void runBare() throws Throwable {
        try {
          setUp();
          runTest();
        } finally {
          tearDown();
        }
      }
    
      @Override
      protected void tearDown() {
        stack.runTearDown();
      }
    
      static final Exception EXCEPTION = new Exception();
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 2.8K bytes
    - Viewed (0)
Back to top