- Sort Score
- Result 10 results
- Languages All
Results 291 - 300 of 803 for connecting (0.05 sec)
-
tests/test_tutorial/test_websockets/test_tutorial003.py
def test_websocket_handle_disconnection(client: TestClient): with ( client.websocket_connect("/ws/1234") as connection, client.websocket_connect("/ws/5678") as connection_two, ): connection.send_text("Hello from 1234") data1 = connection.receive_text() assert data1 == "You wrote: Hello from 1234" data2 = connection_two.receive_text()
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Wed Dec 17 21:25:59 UTC 2025 - 1.3K bytes - Viewed (0) -
container-tests/src/test/java/okhttp3/containers/BasicProxyTest.kt
} } @Test fun testUrlConnectionDirect() { testRequest { val url = URI(mockServer.endpoint + "/person?name=peter").toURL() val connection = url.openConnection() as HttpURLConnection assertThat( connection.inputStream .source() .buffer() .readUtf8(), ).contains("Peter the person") } } @Test
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 6.2K bytes - Viewed (1) -
src/main/java/jcifs/internal/smb2/rdma/RdmaTransport.java
log.info("RDMA connection established to {}", delegate.getRemoteAddress()); } catch (IOException e) { log.warn("Failed to establish RDMA connection: {}", e.getMessage()); throw e; } } } /** * Checks if RDMA connection is available. * * @return true if RDMA connection is active */
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 23 05:11:12 UTC 2025 - 8.9K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/rdma/tcp/TcpRdmaConnection.java
socket.setKeepAlive(true); state = RdmaConnectionState.CONNECTED; log.debug("TCP RDMA connection established to {}", remoteAddress); } catch (IOException e) { state = RdmaConnectionState.ERROR; throw new IOException("TCP RDMA connection failed", e); } } @Override public void send(ByteBuffer data, RdmaMemoryRegion region) throws IOException {
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 23 05:11:12 UTC 2025 - 8.8K bytes - Viewed (0) -
okhttp/src/androidMain/baseline-prof.txt
Lokhttp3/internal/connection/ExchangeFinder; Lokhttp3/internal/connection/FastFallbackExchangeFinder; Lokhttp3/internal/connection/RealCall$AsyncCall; Lokhttp3/internal/connection/RealCall$CallReference; Lokhttp3/internal/connection/RealCall$timeout$1; Lokhttp3/internal/connection/RealCall; Lokhttp3/internal/connection/RealConnection; Lokhttp3/internal/connection/RealConnectionPool$cleanupTask$1; Lokhttp3/internal/connection/RealConnectionPool;
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Mon Dec 30 23:28:56 UTC 2024 - 127.9K bytes - Viewed (1) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ReusePlan.kt
*/ package okhttp3.internal.connection /** Reuse a connection from the pool. */ internal class ReusePlan( val connection: RealConnection, ) : RoutePlanner.Plan { override val isReady = true override fun connectTcp() = error("already connected") override fun connectTlsEtc() = error("already connected") override fun handleSuccess() = connection
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 1K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http/SocketFailureTest.kt
class SocketClosingEventListener : EventListener() { var shouldClose: Boolean = false var lastSocket: Socket? = null override fun connectionAcquired( call: Call, connection: Connection, ) { lastSocket = connection.socket() } override fun requestHeadersStart(call: Call) { if (shouldClose) { lastSocket!!.close() } } } @Test
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Jul 29 21:11:09 UTC 2025 - 3K bytes - Viewed (0) -
internal/http/close.go
// Without this closing connection would disallow re-using // the same connection for future uses. // - http://stackoverflow.com/a/17961593/4465767 defer respBody.Close() xioutil.DiscardReader(respBody) }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 1.7K bytes - Viewed (0) -
src/test/java/jcifs/smb/SmbTreeHandleImplTest.java
@DisplayName("getSession returns underlying session from tree connection") void getSessionReturnsUnderlying() { // Verifies getSession() exposes the session provided by the connection assertSame(session, handle.getSession()); verify(treeConnection).getSession(); } @Test @DisplayName("ensureDFSResolved forwards to tree connection with locator") void ensureDFSResolvedDelegates() throws Exception {Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 14.4K bytes - Viewed (0) -
docs/en/docs/deployment/https.md
After this, the client and the server have an **encrypted TCP connection**, this is what TLS provides. And then they can use that connection to start the actual **HTTP communication**. And that's what **HTTPS** is, it's just plain **HTTP** inside a **secure TLS connection** instead of a pure (unencrypted) TCP connection. /// tip
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Sun Aug 31 19:34:08 UTC 2025 - 14.3K bytes - Viewed (0)