- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for shutdown (0.23 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
functionCalled.await(); assertThat(output.toString()).contains(function.toString()); } finally { functionBlocking.countDown(); executor.shutdown(); } } @J2ktIncompatible @GwtIncompatible // lazyTransform public void testLazyTransform() throws Exception { FunctionSpy<Object, String> spy = new FunctionSpy<>(constant("bar"));
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
fastapi/routing.py
Python - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Tue Apr 02 02:48:51 GMT 2024 - 170.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
functionCalled.await(); assertThat(output.toString()).contains(function.toString()); } finally { functionBlocking.countDown(); executor.shutdown(); } } @J2ktIncompatible @GwtIncompatible // lazyTransform public void testLazyTransform() throws Exception { FunctionSpy<Object, String> spy = new FunctionSpy<>(constant("bar"));
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
fastapi/applications.py
Python - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Tue Apr 02 02:48:51 GMT 2024 - 172.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/URLConnectionTest.kt
assertFailsWith<IOException> { getResponse(request) } } @Test fun connectRetriesUntilConnectedOrFailed() { val request = newRequest("/foo") server.shutdown() assertFailsWith<IOException> { getResponse(request) } } @Test fun requestBodySurvivesRetriesWithFixedLength() { testRequestBodySurvivesRetries(TransferKind.FIXED_LENGTH)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 131.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallTest.kt
) val call = client.newCall(Request(server.url("/"))) val response = call.execute() assertThat(response.header("a\tb")).isEqualTo("c") } @Test fun connectFails() { server.shutdown() executeSynchronously("/") .assertFailure(IOException::class.java) } @Test fun requestBodySurvivesRetries() { server.enqueue(MockResponse())
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 142.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CacheTest.kt
val cached = cacheGet(cache, request) if (shouldWriteToCache) { assertThat(cached).isNotNull() cached!!.body.close() } else { assertThat(cached).isNull() } server.shutdown() // tearDown() isn't sufficient; this test starts multiple servers } private fun assertSubsequentResponseCached( initialResponseCode: Int, finalResponseCode: Int, ) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 108.6K bytes - Viewed (0) -
cmd/server_test.go
s.accessKey = s.testServer.AccessKey s.secretKey = s.testServer.SecretKey } func (s *TestSuiteCommon) RestartTestServer(c *check) { // Shutdown. s.testServer.cancel() s.testServer.Server.Close() s.testServer.Obj.Shutdown(context.Background()) // Restart. ctx, cancel := context.WithCancel(context.Background()) s.testServer.cancel = cancel
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 108K bytes - Viewed (0) -
okhttp-android/src/main/baseline-prof.txt
HSPLokhttp3/internal/concurrent/TaskQueue;->schedule(Lokhttp3/internal/concurrent/Task;J)V HSPLokhttp3/internal/concurrent/TaskQueue;->scheduleAndDecide$okhttp(Lokhttp3/internal/concurrent/Task;JZ)Z HSPLokhttp3/internal/concurrent/TaskQueue;->shutdown()V HSPLokhttp3/internal/concurrent/TaskRunner$RealBackend;-><init>(Ljava/util/concurrent/ThreadFactory;)V HSPLokhttp3/internal/concurrent/TaskRunner$RealBackend;->coordinatorNotify(Lokhttp3/internal/concurrent/TaskRunner;)V
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Mar 21 11:22:00 GMT 2022 - 127.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/LocalCacheTest.java
threadAboutToBlockForRefresh.set(Thread.currentThread()); assertThat(cache.getOrLoad("test")).isEqualTo("testReload"); } finally { refreshExecutor.shutdown(); } } public void testSetRemovalListener() { RemovalListener<Object, Object> testListener = TestingRemovalListeners.nullRemovalListener(); LocalCache<Object, Object> map =
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Mar 14 23:06:48 GMT 2024 - 112.3K bytes - Viewed (0)