Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 228 for ShutDown (0.08 sec)

  1. tests/test_tutorial/test_events/test_tutorial002.py

            response = client.get("/items/")
            assert response.status_code == 200, response.text
            assert response.json() == [{"name": "Foo"}]
        with open("log.txt") as log:
            assert "Application shutdown" in log.read()
    
    
    def test_openapi_schema(app: FastAPI):
        with TestClient(app) as client:
            response = client.get("/openapi.json")
            assert response.status_code == 200, response.text
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Wed Oct 18 12:36:40 UTC 2023
    - 1.4K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/DispatcherCleanupTest.kt

            ) {
              response.close()
            }
          }
        repeat(10_000) {
          okhttp.newCall(Request.Builder().url(server.url("/")).build()).enqueue(callback)
        }
        okhttp.dispatcher.executorService.shutdown()
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.2K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt

              this.writer = null
              taskQueue.execute("$name writer close", cancelable = false) {
                writerToClose.closeQuietly()
              }
            }
    
            this.taskQueue.shutdown()
          }
    
          streamsToClose =
            when {
              writer == null -> streams
              else -> null
            }
        }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 01 14:21:25 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  4. samples/guide/src/main/java/okhttp3/recipes/kt/DevServer.kt

          client.newCall(request).execute().use { response ->
            if (!response.isSuccessful) throw IOException("Unexpected code $response")
    
            println(response.request.url)
          }
        } finally {
          server.shutdown()
        }
      }
    }
    
    fun main() {
      DevServer().run()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  5. guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

        assertTrue(future.isDone());
    
        assertTrue(successLatch.await(200, MILLISECONDS));
        assertTrue(listenerLatch.await(200, MILLISECONDS));
    
        latch.countDown();
    
        exec.shutdown();
        exec.awaitTermination(100, MILLISECONDS);
      }
    
      /**
       * Tests that all listeners complete, even if they were added before or after the future was
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 18:30:30 UTC 2023
    - 6K bytes
    - Viewed (0)
  6. samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/ClientAndServer.java

            .url("http://publicobject.com/helloworld.txt")
            .build();
    
        try (Response response = client.newCall(request).execute()) {
          System.out.println(response.body().string());
        }
    
        server.shutdown();
        socketFile.delete();
      }
    
      public static void main(String... args) throws Exception {
        new ClientAndServer().run();
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Dec 24 03:46:30 UTC 2018
    - 2.1K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/mylasta/direction/sponsor/FessCurtainFinallyHook.java

                method.invoke(null, (Object[]) null);
            } catch (final ClassNotFoundException e) {
                // ignore
            } catch (final Exception e) {
                logger.warn("Could not shutdown Commons HttpClient.", e);
            }
        }
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  8. cmd/erasure.go

    func (er erasureObjects) NewNSLock(bucket string, objects ...string) RWLocker {
    	return er.nsMutex.NewNSLock(er.getLockers, bucket, objects...)
    }
    
    // Shutdown function for object storage interface.
    func (er erasureObjects) Shutdown(ctx context.Context) error {
    	// Add any object layer shutdown activities here.
    	closeStorageDisks(er.getDisks()...)
    	return nil
    }
    
    // defaultWQuorum write quorum based on setDriveCount and defaultParityCount
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  9. mockwebserver/api/mockwebserver3.api

    public abstract class mockwebserver3/Dispatcher {
    	public fun <init> ()V
    	public abstract fun dispatch (Lmockwebserver3/RecordedRequest;)Lmockwebserver3/MockResponse;
    	public fun peek ()Lmockwebserver3/MockResponse;
    	public fun shutdown ()V
    }
    
    public final class mockwebserver3/MockResponse {
    	public static final field Companion Lmockwebserver3/MockResponse$Companion;
    	public fun <init> ()V
    	public fun <init> (I)V
    	public fun <init> (ILokhttp3/Headers;)V
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Jan 03 21:59:45 UTC 2023
    - 12.7K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/ListenableFutureTester.java

              }
            },
            exec);
    
        assertEquals(1, latch.getCount());
        assertFalse(future.isDone());
        assertFalse(future.isCancelled());
      }
    
      public void tearDown() {
        exec.shutdown();
      }
    
      public void testCompletedFuture(@Nullable Object expectedValue)
          throws InterruptedException, ExecutionException {
        assertTrue(future.isDone());
        assertFalse(future.isCancelled());
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 3.3K bytes
    - Viewed (0)
Back to top