- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 2,378 for connectTo (0.21 sec)
-
okhttp/src/test/java/okhttp3/CallTest.kt
val connect1 = server.takeRequest() assertThat(connect1.requestLine).isEqualTo("CONNECT android.com:443 HTTP/1.1") assertThat(connect1.headers["Proxy-Authorization"]).isNull() val connect2 = server.takeRequest() assertThat(connect2.requestLine).isEqualTo("CONNECT android.com:443 HTTP/1.1") assertThat(connect2.headers["Proxy-Authorization"]).isEqualTo("password")
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 10 19:46:48 UTC 2024 - 142.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectionUser.kt
) fun connectionConnectEnd( connection: Connection, route: Route, ) fun connectFailed( route: Route, protocol: Protocol?, e: IOException, ) fun connectionAcquired(connection: Connection) fun acquireConnectionNoEvents(connection: RealConnection) fun releaseConnectionNoEvents(): Socket? fun connectionReleased(connection: Connection)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Fri Apr 05 03:30:42 UTC 2024 - 2.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt
* automatically send ping frames until either the connection fails or it is closed. This keeps * the connection alive and may detect connectivity failures. * * If the server does not respond to each ping with a pong within `interval`, this client will * assume that connectivity has been lost. When this happens on a web socket the connection is
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 06 04:21:33 UTC 2024 - 52K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/MessageHubBackedClient.java
public class MessageHubBackedClient implements MessagingClient { private final OutgoingConnector connector; private final ExecutorFactory executorFactory; public MessageHubBackedClient(OutgoingConnector connector, ExecutorFactory executorFactory) { this.connector = connector; this.executorFactory = executorFactory; } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/CallConnectionUser.kt
override fun connectionConnectEnd( connection: Connection, route: Route, ) { poolConnectionListener.connectEnd(connection, route, call) } override fun connectionAcquired(connection: Connection) { eventListener.connectionAcquired(call, connection) } override fun acquireConnectionNoEvents(connection: RealConnection) { call.acquireConnectionNoEvents(connection) }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Mar 06 17:33:38 UTC 2024 - 3.6K bytes - Viewed (0) -
src/database/sql/example_cli_test.go
package sql_test import ( "context" "database/sql" "flag" "log" "os" "os/signal" "time" ) var pool *sql.DB // Database connection pool. func Example_openDBCLI() { id := flag.Int64("id", 0, "person ID to find") dsn := flag.String("dsn", os.Getenv("DSN"), "connection data source name") flag.Parse() if len(*dsn) == 0 { log.Fatal("missing dsn flag") } if *id == 0 { log.Fatal("missing person ID")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun May 08 17:27:54 UTC 2022 - 2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/doc.go
// these proxies allow the inter-connection of WebSocket and SPDY // streaming connections. // // The stream translator proxy is used for the RemoteCommand // subprotocol (e.g. kubectl exec, cp, and attach), and it connects // the output streams of a WebSocket connection (e.g. STDIN, STDOUT, // STDERR, TTY resize, and error streams) to the input streams of a // SPDY connection. //
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 17:56:46 UTC 2024 - 1.7K bytes - Viewed (0) -
pilot/pkg/autoregistration/controller.go
} // OnDisconnect determines whether a connected proxy represents a non-Kubernetes // workload and, if that's the case, terminates special processing required for that type // of workloads, such as auto-registration, health status updates, etc. // // If proxy represents a workload (be it auto-registered or not), WorkloadEntry resource // will be updated to reflect that the proxy is no longer connected to this particular `istiod` // instance. //
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 26.4K bytes - Viewed (0) -
src/syscall/tables_js.go
ECONNABORTED: "Connection aborted", ECONNRESET: "Connection reset by peer", ENOBUFS: "No buffer space available", EISCONN: "Socket is already connected", ENOTCONN: "Socket is not connected", ESHUTDOWN: "Can't send after socket shutdown", ETIMEDOUT: "Connection timed out", ECONNREFUSED: "Connection refused", EHOSTDOWN: "Host is down",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 28 18:17:57 UTC 2021 - 19.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
val connect1 = server.takeRequest() assertThat(connect1.requestLine).isEqualTo("CONNECT android.com:$port HTTP/1.1") assertThat(connect1.headers["Proxy-Authorization"]).isNull() val connect2 = server.takeRequest() assertThat(connect2.requestLine).isEqualTo("CONNECT android.com:$port HTTP/1.1") assertThat(connect2.headers["Proxy-Authorization"]).isEqualTo("password")
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 75.3K bytes - Viewed (0)