Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for runNext (0.05 sec)

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

        private final Deque<Runnable> tasks = new ArrayDeque<>();
    
        @Override
        public void execute(Runnable task) {
          tasks.add(task);
        }
    
        private void runNext() {
          tasks.removeFirst().run();
        }
      }
    
      public void testAsyncReload() throws Exception {
        AtomicInteger loadCount = new AtomicInteger();
        AtomicInteger reloadCount = new AtomicInteger();
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 3.6K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

          tasks.add(command);
        }
    
        boolean hasNext() {
          return !tasks.isEmpty();
        }
    
        void runNext() {
          assertTrue("expected at least one task to run", hasNext());
          tasks.remove().run();
        }
    
        void runAll() {
          while (hasNext()) {
            runNext();
          }
        }
      }
    
      private FakeExecutor fakePool;
      private SequentialExecutor e;
    
      @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  3. 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
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/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 Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  5. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureFallbackAtomicHelperTest.java

      public static TestSuite suite() {
        // we create a test suite containing a test for every AbstractFutureTest test method and we
        // set it as the name of the test.  Then in runTest we can reflectively load and invoke the
        // corresponding method on AbstractFutureTest in the correct classloader.
        TestSuite suite = new TestSuite(AbstractFutureFallbackAtomicHelperTest.class.getName());
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/AggregateFutureStateFallbackAtomicHelperTest.java

      public static TestSuite suite() {
        // we create a test suite containing a test for every FuturesTest test method and we
        // set it as the name of the test.  Then in runTest we can reflectively load and invoke the
        // corresponding method on FuturesTest in the correct classloader.
        TestSuite suite = new TestSuite(AggregateFutureStateFallbackAtomicHelperTest.class.getName());
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/AbstractFutureFallbackAtomicHelperTest.java

      public static TestSuite suite() {
        // we create a test suite containing a test for every AbstractFutureTest test method and we
        // set it as the name of the test.  Then in runTest we can reflectively load and invoke the
        // corresponding method on AbstractFutureTest in the correct classloader.
        TestSuite suite = new TestSuite(AbstractFutureFallbackAtomicHelperTest.class.getName());
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  9. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Aug 10 19:54:19 UTC 2025
    - 2.9K bytes
    - Viewed (0)
  10. fess-crawler/src/test/resources/extractor/eml/sample4.eml

    Workshop Nr. 4:
    Seifen gießen. Eine hautfreundliche Rohseife wird eingeschmolzen, mit Lebensmittelfarben und reinen ätherischen Ölen
    versetzt und in Formen gegossen. Ein kleiner Exkurs in die Chemie und Geschichte gesiedeter Seifen rundet das Programm
    ab.
    Das Museumsdorf Baruther Glashütte ist ein Technisches Denkmal im Süden des Landkreises Teltow-Fläming in
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jan 07 09:15:11 UTC 2018
    - 681K bytes
    - Viewed (0)
Back to top