- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 1,044 for socket (0.1 sec)
-
docs/en/docs/reference/testclient.md
# Test Client - `TestClient` You can use the `TestClient` class to test FastAPI applications without creating an actual HTTP and socket connection, just communicating directly with the FastAPI code. Read more about it in the [FastAPI docs for Testing](https://fastapi.tiangolo.com/tutorial/testing/). You can import it directly from `fastapi.testclient`: ```python from fastapi.testclient import TestClient ```
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Thu Apr 18 19:53:19 UTC 2024 - 450 bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2ExchangeCodec.kt
} else { Protocol.HTTP_2 } @Volatile private var canceled = false override val isResponseComplete: Boolean get() = stream?.isSourceComplete == true override val socket: Socket get() = stream!! override fun createRequestBody( request: Request, contentLength: Long, ): Sink = stream!!.sink override fun writeRequestHeaders(request: Request) {Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Jul 29 21:11:09 UTC 2025 - 7K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketExtensions.kt
* ``` * * If any other extension or parameter is specified, then [unknownValues] will be true. Such * responses should be refused as their web socket extensions will not be understood. * * Note that [java.util.zip.Deflater] is hardcoded to use 15 bits (32 KiB) for * `client_max_window_bits` and [java.util.zip.Inflater] is hardcoded to use 15 bits (32 KiB) for
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 8.1K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/CallServerInterceptor.kt
// This is an HTTP/1 upgrade. (This case includes web socket upgrades.) isUpgradeRequest && isUpgradeResponse -> { response .newBuilder() .body( UnreadableResponseBody( response.body.contentType(), response.body.contentLength(), ), ).socket(exchange.upgradeToSocket()) .build()Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Thu Oct 30 13:46:58 UTC 2025 - 7.6K bytes - Viewed (0) -
docs/changelogs/changelog_4x.md
compressing outbound web socket messages. Configure this with 0L to always compress outbound messages and `Long.MAX_VALUE` to never compress outbound messages. The default is 1024L which compresses messages of size 1 KiB and larger. (Inbound messages are compressed or not based on the web socket server's configuration.)Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Apr 17 13:25:31 UTC 2024 - 25.2K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Protocol.kt
* [rfc_7230]: https://tools.ietf.org/html/rfc7230 */ HTTP_1_1("http/1.1"), /** * Chromium's binary-framed protocol that includes header compression, multiplexing multiple * requests on the same socket, and server-push. HTTP/1.1 semantics are layered on SPDY/3. * * Current versions of OkHttp do not support this protocol. */ @Deprecated("OkHttp has dropped support for SPDY. Prefer {@link #HTTP_2}.")
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Mon Jun 23 18:58:57 UTC 2025 - 4.4K bytes - Viewed (0) -
samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/TunnelingUnixSocket.java
import java.net.SocketAddress; import jnr.unixsocket.UnixSocket; import jnr.unixsocket.UnixSocketAddress; import jnr.unixsocket.UnixSocketChannel; /** * Subtype UNIX socket for a higher-fidelity impersonation of TCP sockets. This is named "tunneling" * because it assumes the ultimate destination has a hostname and port. */ final class TunnelingUnixSocket extends UnixSocket { private final File path;
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Feb 12 16:33:52 UTC 2019 - 1.9K bytes - Viewed (0) -
tests/test_ws_router.py
await websocket.accept() await websocket.send_text(pathparam) await websocket.send_text(queryparam) await websocket.close() async def ws_dependency(): return "Socket Dependency" @router.websocket("/router-ws-depends/") async def router_ws_decorator_depends( websocket: WebSocket, data=Depends(ws_dependency) ): await websocket.accept()
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Sun Jun 11 19:08:14 UTC 2023 - 7.5K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/StreamResetException.kt
* limitations under the License. */ package okhttp3.internal.http2 import java.io.IOException /** Thrown when an HTTP/2 stream is canceled without damage to the socket that carries it. */ class StreamResetException( @JvmField val errorCode: ErrorCode,
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 869 bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/RecordedRequest.kt
import okhttp3.HttpUrl import okio.ByteString /** An HTTP request that came into the mock web server. */ public class RecordedRequest( /** * The index of the socket connection that carried this request. If two recorded requests share a * connection index, they also shared a socket connection. */ public val connectionIndex: Int, /** * The index of this exchange on its HTTP connection. A request is uniquely identified by the
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sat Jun 21 20:36:35 UTC 2025 - 3.2K bytes - Viewed (1)