- Sort Score
- Num 10 results
- Language All
Results 1 - 8 of 8 for disconnect (0.07 seconds)
-
src/test/java/org/codelibs/curl/io/IOIntegrationTest.java
} } class MockHttpURLConnection extends HttpURLConnection { MockHttpURLConnection(URL u) { super(u); } @Override public void disconnect() { // Do Nothing } @Override public boolean usingProxy() { return false; } @Override public void connect() throws IOException {Created: Thu Apr 02 15:34:12 GMT 2026 - Last Modified: Sat Mar 21 12:00:34 GMT 2026 - 44.1K bytes - Click Count (0) -
docs_src/websockets_/tutorial003_py310.py
self.active_connections: list[WebSocket] = [] async def connect(self, websocket: WebSocket): await websocket.accept() self.active_connections.append(websocket) def disconnect(self, websocket: WebSocket): self.active_connections.remove(websocket) async def send_personal_message(self, message: str, websocket: WebSocket): await websocket.send_text(message)
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Fri Feb 27 12:34:37 GMT 2026 - 2.5K bytes - Click Count (0) -
docs/en/docs/how-to/custom-docs-ui-assets.md
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 05 18:13:19 GMT 2026 - 7.5K bytes - Click Count (0) -
tests/test_stream_cancellation.py
""" chunks: list[bytes] = [] async def receive(): # type: ignore[no-untyped-def] # Simulate a client that never disconnects, rely on cancellation await anyio.sleep(float("inf")) return {"type": "http.disconnect"} # pragma: no cover async def send(message: dict) -> None: # type: ignore[type-arg] if message["type"] == "http.response.body":Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Fri Feb 27 18:56:47 GMT 2026 - 2.7K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/CacheTest.kt
} @Test fun serverDisconnectsPrematurelyWithNoLengthHeaders() { // Intentionally empty. This case doesn't make sense because there's no // such thing as a premature disconnect when the disconnect itself // indicates the end of the data stream. } private fun testServerPrematureDisconnect(transferKind: TransferKind) { val mockResponse = MockResponse.Builder()
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Fri Mar 20 09:13:37 GMT 2026 - 121K bytes - Click Count (0) -
src/main/java/org/codelibs/curl/CurlRequest.java
Created: Thu Apr 02 15:34:12 GMT 2026 - Last Modified: Sat Mar 21 09:11:12 GMT 2026 - 19.7K bytes - Click Count (0) -
docs/features/calls.md
## Retrying Requests Sometimes connections fail: either a pooled connection was stale and disconnected, or the webserver itself couldn’t be reached. OkHttp will retry the request with a different route if one is available. ## [Calls](https://square.github.io/okhttp/5.x/okhttp/okhttp3/-call/)
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Mar 15 09:01:42 GMT 2026 - 3.9K bytes - Click Count (0) -
CHANGELOG.md
different cipher suite than before! OkHttp's defaults cipher suites are selected for good security and performance. * New: `ConnectionListener` publishes events for connects, disconnects, and use of pooled connections. * Fix: Immediately update the connection's flow control window instead of waiting for the receiving stream to process it.
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Feb 15 11:57:47 GMT 2026 - 36.2K bytes - Click Count (2)