Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 228 for ShutDown (0.1 sec)

  1. okhttp/src/test/java/okhttp3/SocksProxyTest.kt

      private val socksProxy = SocksProxy()
    
      @BeforeEach
      fun setUp(server: MockWebServer) {
        this.server = server
        socksProxy.play()
      }
    
      @AfterEach
      fun tearDown() {
        socksProxy.shutdown()
      }
    
      @Test
      fun proxy() {
        server.enqueue(MockResponse.Builder().body("abc").build())
        server.enqueue(MockResponse.Builder().body("def").build())
        val client =
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java

          }
          barrier.await(); // release the threads!
          barrier.await(); // wait for them all to complete
          assertEquals(1, task.get().intValue());
          assertEquals(1, counter.get());
        }
        executor.shutdown();
      }
    
      @J2ktIncompatible
      @GwtIncompatible // blocking wait
      public void testToString() throws Exception {
        final CountDownLatch enterLatch = new CountDownLatch(1);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 15:41:36 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  3. ci/official/utilities/code_check_changed_files.bats

        echo "You have to re-generate the TF API goldens and have the API changes reviewed."
        echo "Look at the instructions for ':api_compatibility_test -- --update_goldens=True'"
    }
    
    teardown_file() {
        bazel shutdown
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Wed Jan 10 19:39:41 UTC 2024
    - 4K bytes
    - Viewed (0)
  4. samples/crawler/src/main/java/okhttp3/sample/Crawler.java

          executor.execute(() -> {
            try {
              drainQueue();
            } catch (Exception e) {
              e.printStackTrace();
            }
          });
        }
        executor.shutdown();
      }
    
      private void drainQueue() throws Exception {
        for (HttpUrl url; (url = queue.take()) != null; ) {
          if (!fetchedUrls.add(url)) {
            continue;
          }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Aug 12 07:26:27 UTC 2021
    - 4.6K bytes
    - Viewed (0)
  5. ci/official/containers/linux_arm64/devel.usertools/code_check_changed_files.bats

            | grep -v "**** Module" \
            | tee $BATS_TEST_TMPDIR/needs_help.txt
        [[ ! -s $BATS_TEST_TMPDIR/needs_help.txt ]]
    }
    
    teardown_file() {
        bazel shutdown
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Mon Sep 18 14:52:45 UTC 2023
    - 3.6K bytes
    - Viewed (0)
  6. cmd/service.go

    // Global service signal channel.
    var globalServiceSignalCh = make(chan serviceSignal)
    
    // GlobalContext context that is canceled when server is requested to shut down.
    // cancelGlobalContext can be used to indicate server shutdown.
    var GlobalContext, cancelGlobalContext = context.WithCancel(context.Background())
    
    // restartProcess starts a new process passing it the active fd's. It
    // doesn't fork, but starts a new process using the same environment and
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Feb 28 07:02:14 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  7. tests/test_ws_router.py

            data = websocket.receive_text()
            assert data == "a_query_param"
    
    
    def test_wrong_uri():
        """
        Verify that a websocket connection to a non-existent endpoing returns in a shutdown
        """
        client = TestClient(app)
        with pytest.raises(WebSocketDisconnect) as e:
            with client.websocket_connect("/no-router/"):
                pass  # pragma: no cover
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Jun 11 19:08:14 UTC 2023
    - 7.5K bytes
    - Viewed (0)
  8. .github/workflows/CheckBadMerge.groovy

        ]
    
        static void main(String[] commits) {
            println("Commits to check: ${Arrays.toString(commits)}")
            try {
                commits.each { checkCommit(it) }
            } finally {
                THREAD_POOL.shutdown()
            }
        }
    
        static void checkCommit(String commit) {
            List<String> parentCommits = parentCommitsOf(commit)
            if (parentCommits.size() != 2) {
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Tue Dec 19 10:35:44 UTC 2023
    - 6.5K bytes
    - Viewed (0)
  9. mockwebserver/README.md

      RecordedRequest request3 = server.takeRequest();
      assertEquals("/v1/chat/messages/3", request3.getPath());
    
      // Shut down the server. Instances cannot be reused.
      server.shutdown();
    }
    ```
    
    Your unit tests might move the `server` into a field so you can shut it down
    from your test's `tearDown()`.
    
    ### API
    
    #### MockResponse
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Dec 17 15:34:10 UTC 2023
    - 5K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

                listenerLatch.countDown();
              }
            },
            directExecutor());
      }
    
      @Override
      protected void tearDown() throws Exception {
        if (exec != null) {
          exec.shutdown();
        }
    
        super.tearDown();
      }
    
      public void testListenerDoesNotRunUntilTaskCompletes() throws Exception {
    
        // Test default state of not started.
        assertEquals(1, listenerLatch.getCount());
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 4.7K bytes
    - Viewed (0)
Back to top