Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 228 for ShutDown (0.12 sec)

  1. docs/zh/docs/advanced/testing-events.md

    # 测试事件:启动 - 关闭
    
    使用 `TestClient` 和 `with` 语句,在测试中运行事件处理器(`startup` 与 `shutdown`)。
    
    ```Python hl_lines="9-12  20-24"
    {!../../docs_src/app_testing/tutorial003.py!}
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 225 bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

        serializer = ExecutionSequencer.create();
        firstFuture = SettableFuture.create();
        firstCallable = new TestCallable(firstFuture);
      }
    
      @Override
      public void tearDown() throws Exception {
        executor.shutdown();
      }
    
      public void testCallableStartsAfterFirstFutureCompletes() {
        @SuppressWarnings({"unused", "nullness"})
        Future<?> possiblyIgnoredError = serializer.submitAsync(firstCallable, directExecutor());
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  3. android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

        assertTrue(future.isDone());
    
        assertTrue(successLatch.await(200, MILLISECONDS));
        assertTrue(listenerLatch.await(200, MILLISECONDS));
    
        latch.countDown();
    
        exec.shutdown();
        exec.awaitTermination(100, MILLISECONDS);
      }
    
      /**
       * Tests that all listeners complete, even if they were added before or after the future was
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 18:30:30 UTC 2023
    - 6K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/SocksProxy.kt

          Proxy.Type.SOCKS,
          InetSocketAddress.createUnresolved("localhost", serverSocket!!.localPort),
        )
      }
    
      fun connectionCount(): Int = connectionCount.get()
    
      fun shutdown() {
        serverSocket!!.close()
        executor.shutdown()
        if (!executor.awaitTermination(5, TimeUnit.SECONDS)) {
          throw IOException("Gave up waiting for executor to shut down")
        }
      }
    
      private fun service(from: Socket) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/RouteFailureTest.kt

          .assertSuccessful()
          .assertCode(200)
    
        println("server1.requestCount ${server1.requestCount}")
        assertThat(server1.requestCount).isEqualTo(1)
    
        // Shutdown the proxy server
        if (cleanShutdown) {
          server1.shutdown()
        }
    
        // Now redirect with DNS to proxyServer2
        // Then redirect socket connection to server2
        dns["myproxy"] = listOf(proxyServer2)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue May 14 17:48:07 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/DispatcherTest.kt

        proceed.countDown()
        t1.join()
        assertThat(idle.get()).isTrue()
      }
    
      @Test
      fun executionRejectedImmediately() {
        val request = newRequest("http://a/1")
        executor.shutdown()
        client.newCall(request).enqueue(callback)
        callback.await(request.url).assertFailure(InterruptedIOException::class.java)
        assertThat(listener.recordedEventTypes())
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Fri Apr 05 03:30:42 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

        override fun execute(
          taskRunner: TaskRunner,
          runnable: Runnable,
        ) {
          executor.execute(runnable)
        }
    
        fun shutdown() {
          executor.shutdown()
        }
      }
    
      companion object {
        val logger: Logger = Logger.getLogger(TaskRunner::class.java.name)
    
        @JvmField
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 29 00:33:04 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

          queue.enqueue(countDownEvent(latch));
          assertEquals(0, counters.size());
          queue.dispatch();
          latch.await();
          assertEquals(multiset(listener, 4), counters);
        } finally {
          service.shutdown();
        }
      }
    
      public void testEnqueueAndDispatch_multithreaded_withThrowingRunnable()
          throws InterruptedException {
        Object listener = new Object();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Feb 09 22:57:07 UTC 2022
    - 8.2K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

          queue.enqueue(countDownEvent(latch));
          assertEquals(0, counters.size());
          queue.dispatch();
          latch.await();
          assertEquals(multiset(listener, 4), counters);
        } finally {
          service.shutdown();
        }
      }
    
      public void testEnqueueAndDispatch_multithreaded_withThrowingRunnable()
          throws InterruptedException {
        Object listener = new Object();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Feb 09 22:57:07 UTC 2022
    - 8.2K bytes
    - Viewed (0)
  10. mockwebserver-deprecated/api/mockwebserver.api

    	public fun <init> ()V
    	public abstract fun dispatch (Lokhttp3/mockwebserver/RecordedRequest;)Lokhttp3/mockwebserver/MockResponse;
    	public fun peek ()Lokhttp3/mockwebserver/MockResponse;
    	public fun shutdown ()V
    }
    
    public final class okhttp3/mockwebserver/MockResponse : java/lang/Cloneable {
    	public static final field Companion Lokhttp3/mockwebserver/MockResponse$Companion;
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jul 22 12:28:51 UTC 2023
    - 10.2K bytes
    - Viewed (0)
Back to top