- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 228 for ShutDown (0.1 sec)
-
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) -
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) -
ci/official/utilities/code_check_changed_files.bats
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Wed Jan 10 19:39:41 UTC 2024 - 4K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
.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) -
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) -
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)