- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 880 for Close (0.2 sec)
-
docs_src/dependencies/tutorial008_an.py
async def dependency_a(): dep_a = generate_dep_a() try: yield dep_a finally: dep_a.close() async def dependency_b(dep_a: Annotated[DepA, Depends(dependency_a)]): dep_b = generate_dep_b() try: yield dep_b finally: dep_b.close(dep_a) async def dependency_c(dep_b: Annotated[DepB, Depends(dependency_b)]): dep_c = generate_dep_c() try:
Python - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Sat Mar 18 12:29:59 GMT 2023 - 531 bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketReaderTest.kt
} } @Test fun closeReservedSetThrows() { data.write("880203ec".decodeHex()) // Close with code 1004 data.write("880203ed".decodeHex()) // Close with code 1005 data.write("880203ee".decodeHex()) // Close with code 1006 for (i in 1015..2999) { data.write(("8802" + format("%04X", i)).decodeHex()) // Close with code 'i' } var count = 0 while (!data.exhausted()) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 14.4K bytes - Viewed (0) -
android/guava/src/com/google/common/io/CharStreams.java
@Override public void flush() {} @Override public void close() {} @Override public String toString() { return "CharStreams.nullWriter()"; } } /** * Returns a Writer that sends all output to the given {@link Appendable} target. Closing the * writer will close the target if it is {@link Closeable}, and flushing the writer will flush the
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed May 17 14:35:11 GMT 2023 - 10.9K bytes - Viewed (0) -
internal/event/target/amqp.go
return err } // Delete the event from store. return target.store.Del(key.Name) } // Close - does nothing and available for interface compatibility. func (target *AMQPTarget) Close() error { close(target.quitCh) if target.conn != nil { return target.conn.Close() } return nil } func (target *AMQPTarget) init() error { return target.initOnce.Do(target.initAMQP) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 10K bytes - Viewed (0) -
internal/ioutil/ioutil_test.go
if err != context.DeadlineExceeded { t.Error("DeadlineWriter shouldn't be successful - should return context.DeadlineExceeded") } w.Close() w = NewDeadlineWriter(&sleepWriter{timeout: 100 * time.Millisecond}, 600*time.Millisecond) n, err := w.Write([]byte("abcd")) w.Close() if err != nil { t.Errorf("DeadlineWriter should succeed but failed with %s", err) } if n != 4 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 02 11:02:31 GMT 2024 - 5.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/CharSourceTest.java
static final CharSource BROKEN_CLOSE_SOURCE = new TestCharSource("ABC", CLOSE_THROWS); static final CharSource BROKEN_OPEN_SOURCE = new TestCharSource("ABC", OPEN_THROWS); static final CharSink BROKEN_WRITE_SINK = new TestCharSink(WRITE_THROWS); static final CharSink BROKEN_CLOSE_SINK = new TestCharSink(CLOSE_THROWS); static final CharSink BROKEN_OPEN_SINK = new TestCharSink(OPEN_THROWS);
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 13K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
// Confirm all sent messages were received, followed by a client-initiated close. val server = serverListener.assertOpen() for (i in 0 until messageCount) { serverListener.assertBinaryMessage(message) } serverListener.assertClosing(1001, "") // When the server acknowledges the close the connection shuts down gracefully. server.close(1000, null) clientListener.assertClosing(1000, "")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 35.2K bytes - Viewed (1) -
tests/test_ws_router.py
await websocket.accept() await websocket.send_text("Hello, world!") await websocket.close() @router.websocket_route("/router") async def routerindex(websocket: WebSocket): await websocket.accept() await websocket.send_text("Hello, router!") await websocket.close() @prefix_router.websocket_route("/") async def routerprefixindex(websocket: WebSocket):
Python - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Sun Jun 11 19:08:14 GMT 2023 - 7.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/ByteSourceTest.java
private static final ByteSource BROKEN_CLOSE_SOURCE = new TestByteSource(new byte[10], CLOSE_THROWS); private static final ByteSource BROKEN_OPEN_SOURCE = new TestByteSource(new byte[10], OPEN_THROWS); private static final ByteSource BROKEN_READ_SOURCE = new TestByteSource(new byte[10], READ_THROWS); private static final ByteSink BROKEN_CLOSE_SINK = new TestByteSink(CLOSE_THROWS);
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 16.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ConnectionListenerTest.kt
server!!.enqueue(MockResponse()) server!!.enqueue(MockResponse()) client.newCall(Request(server!!.url("/"))) .execute().close() client.newCall(Request(server!!.url("/"))) .execute().close() assertThat(listener.recordedEventTypes()).containsExactly( "ConnectStart", "ConnectEnd", "ConnectionAcquired", "ConnectionReleased",
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 9.6K bytes - Viewed (0)