Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 228 for ShutDown (0.08 sec)

  1. tests/test_router_events.py

        def app_startup() -> None:
            state.app_startup = True
    
        @app.on_event("shutdown")
        def app_shutdown() -> None:
            state.app_shutdown = True
    
        router = APIRouter()
    
        @router.on_event("startup")
        def router_startup() -> None:
            state.router_startup = True
    
        @router.on_event("shutdown")
        def router_shutdown() -> None:
            state.router_shutdown = True
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat Aug 24 19:09:52 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  2. mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt

      @Test
      fun shutdownWithoutStart() {
        val server = MockWebServer()
        server.shutdown()
      }
    
      @Test
      fun closeViaClosable() {
        val server: Closeable = MockWebServer()
        server.close()
      }
    
      @Test
      fun shutdownWithoutEnqueue() {
        val server = MockWebServer()
        server.start()
        server.shutdown()
      }
    
      @Test
      fun portImplicitlyStarts() {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  3. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

      @Synchronized
      @Throws(IOException::class)
      fun shutdown() {
        if (shutdown) return
        shutdown = true
    
        if (!started) return // Nothing to shut down.
        val serverSocket = this.serverSocket ?: return // If this is null, start() must have failed.
    
        // Cause acceptConnections() to break out.
        serverSocket.close()
    
        // Await shutdown.
        for (queue in taskRunner.activeQueues()) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 37.4K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java

          enterRun.countDown();
          try {
            exitRun.await();
          } catch (InterruptedException e) {
            throw new RuntimeException(e);
          }
        }
    
        @Override
        protected void shutDown() {
          assertTrue(startUpCalled);
          assertTrue(runCalled);
          assertFalse(shutDownCalled);
          shutDownCalled = true;
          assertEquals(expectedShutdownState, state());
        }
    
        @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

        assertFalse(testExecutor.isTerminated());
        mock.assertLastMethodCalled("isTerminated");
        assertFalse(testExecutor.isShutdown());
        mock.assertLastMethodCalled("isShutdown");
        testExecutor.shutdown();
        mock.assertLastMethodCalled("shutdown");
        List<Runnable> list = testExecutor.shutdownNow();
        mock.assertLastMethodCalled("shutdownNow");
        assertEquals(ImmutableList.of(), list);
      }
    
      public void testExecute() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  6. mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/DeprecationBridge.kt

          return delegate.dispatch(request.unwrap()).wrap()
        }
    
        override fun peek(): mockwebserver3.MockResponse {
          return delegate.peek().wrap()
        }
    
        override fun shutdown() {
          delegate.shutdown()
        }
      }
    }
    
    internal fun MockResponse.wrap(): mockwebserver3.MockResponse {
      val result = mockwebserver3.MockResponse.Builder()
      val copyFromWebSocketListener = webSocketListener
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  7. internal/event/target/nats_tls_contrib_test.go

    	natsserver "github.com/nats-io/nats-server/v2/test"
    )
    
    func TestNatsConnTLSCustomCA(t *testing.T) {
    	s, opts := natsserver.RunServerWithConfig(filepath.Join("testdata", "contrib", "nats_tls.conf"))
    	defer s.Shutdown()
    
    	clientConfig := &NATSArgs{
    		Enable: true,
    		Address: xnet.Host{
    			Name:      "localhost",
    			Port:      (xnet.Port(opts.Port)),
    			IsPortSet: true,
    		},
    		Subject:       "test",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/AbstractListeningExecutorServiceTest.java

      /** Simple same thread listening executor service that doesn't handle shutdown. */
      private static class TestListeningExecutorService extends AbstractListeningExecutorService {
    
        @Override
        public void execute(Runnable runnable) {
          assertThat(runnable).isInstanceOf(TrustedListenableFutureTask.class);
          runnable.run();
        }
    
        @Override
        public void shutdown() {}
    
        @Override
        public List<Runnable> shutdownNow() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 3.2K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/AbstractListeningExecutorServiceTest.java

      /** Simple same thread listening executor service that doesn't handle shutdown. */
      private static class TestListeningExecutorService extends AbstractListeningExecutorService {
    
        @Override
        public void execute(Runnable runnable) {
          assertThat(runnable).isInstanceOf(TrustedListenableFutureTask.class);
          runnable.run();
        }
    
        @Override
        public void shutdown() {}
    
        @Override
        public List<Runnable> shutdownNow() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 3.2K bytes
    - Viewed (0)
  10. android/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)
Back to top