- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 82 for isopen (0.25 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
/** * Returns true if this stream is open. A stream is open until either: * * * A `SYN_RESET` frame abnormally terminates the stream. * * Both input and output streams have transmitted all data and headers. * * Note that the input stream may continue to yield data even after a stream reports itself as * not open. This is because input data is buffered. */ val isOpen: Boolean get() {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
} else { writePing(false, INTERVAL_PING, 0) return@schedule pingIntervalNanos } } } } /** * Returns the number of [open streams][Http2Stream.isOpen] on this connection. */ fun openStreamCount(): Int = this.withLock { streams.size } fun getStream(id: Int): Http2Stream? = this.withLock { streams[id] }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
} sink1.writeUtf8("def") sink1.close() assertFailsWith<ConnectionShutdownException> { connection.newStream(headerEntries("c", "cola"), true) } assertThat(stream1.isOpen).isTrue() assertThat(stream2.isOpen).isFalse() assertThat(connection.openStreamCount()).isEqualTo(1) // Verify the peer received what was expected. val synStream1 = peer.takeFrame()
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 75.4K bytes - Viewed (0) -
istioctl/pkg/workload/workload.go
func unstructureIstioType(spec any) (map[string]any, error) { b, err := yaml.Marshal(spec) if err != nil { return nil, err } iSpec := map[string]any{} err = yaml.Unmarshal(b, &iSpec) if err != nil { return nil, err } return iSpec, nil } func convertToUnsignedInt32Map(s []string) map[string]uint32 { out := make(map[string]uint32, len(s)) for _, l := range s {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed Apr 17 20:06:41 GMT 2024 - 25.5K bytes - Viewed (0) -
fastapi/security/open_id_connect_url.py
Aleksei Kotenko <******@****.***> 1712026131 +0100
Python - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Tue Apr 02 02:48:51 GMT 2024 - 2.7K bytes - Viewed (0) -
istioctl/pkg/dashboard/dashboard.go
CommandShort: "Open admin web UI for a proxy", CommandLong: `Open the admin dashboard for a proxy, like envoy and ztunnel pods`, CommandExample: ` # Open envoy admin dashboard for the productpage-123-456.default pod istioctl dashboard proxy productpage-123-456.default # Open envoy admin dashboard for one pod under a deployment istioctl dashboard proxy deployment/productpage-v1
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Mon Apr 15 01:29:35 GMT 2024 - 20.5K bytes - Viewed (0) -
docs/en/docs/help-fastapi.md
You can: * <a href="https://github.com/tiangolo" class="external-link" target="_blank">Follow me on **GitHub**</a>. * See other Open Source projects I have created that could help you. * Follow me to see when I create a new Open Source project.
Plain Text - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Thu Apr 18 19:53:19 GMT 2024 - 13.7K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/WebSocketEcho.java
client.newWebSocket(request, this); // Trigger shutdown of the dispatcher's executor so this process exits immediately. client.dispatcher().executorService().shutdown(); } @Override public void onOpen(WebSocket webSocket, Response response) { webSocket.send("Hello..."); webSocket.send("...World!"); webSocket.send(ByteString.decodeHex("deadbeef")); webSocket.close(1000, "Goodbye, World!"); }
Java - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Apr 04 11:40:21 GMT 2024 - 1.6K bytes - Viewed (0) -
docs/pl/docs/help-fastapi.md
Możesz: * <a href="https://github.com/tiangolo" class="external-link" target="_blank">Śledzić mnie na **GitHubie**</a>. * Zobacz inne projekty open source, które stworzyłem, a mogą być dla Ciebie pomocne. * Śledź mnie, aby dostać powiadomienie, gdy utworzę nowy projekt open source.
Plain Text - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Thu Apr 18 19:53:19 GMT 2024 - 14.9K bytes - Viewed (0) -
docs/zh/docs/advanced/events.md
{!../../../docs_src/events/tutorial002.py!} ``` 此处,`shutdown` 事件处理器函数在 `log.txt` 中写入一行文本 `Application shutdown`。 !!! info "说明" `open()` 函数中,`mode="a"` 指的是**追加**。因此这行文本会添加在文件已有内容之后,不会覆盖之前的内容。 !!! tip "提示" 注意,本例使用 Python `open()` 标准函数与文件交互。 这个函数执行 I/O(输入/输出)操作,需要等待内容写进磁盘。 但 `open()` 函数不支持使用 `async` 与 `await`。 因此,声明事件处理函数要使用 `def`,不能使用 `asnyc def`。 !!! info "说明"
Plain Text - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Thu Apr 18 19:53:19 GMT 2024 - 1.7K bytes - Viewed (0)