- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 228 for ShutDown (0.08 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)