connect - Code Search

mockwebserver/src/test/java/mockwebserver3/MockResponseSniTest.kt

    assertThat(recordedRequest.requestUrl!!.host).isEqualTo("cash.app")
    assertThat(recordedRequest.handshakeServerNames).containsExactly("cash.app")
  }

  /**
   * Connect to [hostnameOrIpAddress] and return what was received. To fake an arbitrary hostname we
   * tell MockWebServer to act as a proxy.
   */
  private fun requestToHostnameViaProxy(hostnameOrIpAddress: String): RecordedRequest {

Plain Text

- Registered: Fri May 03 11:42:14 GMT 2024

- Last Modified: Mon Jan 08 01:13:22 GMT 2024

- 5.9K bytes

- Viewed (1)

github.com/square/okhttp

okhttp/src/main/kotlin/okhttp3/EventListener.kt

 *
 *  * call ([callStart], [callEnd], [callFailed])
 *    * proxy selection ([proxySelectStart], [proxySelectEnd])
 *    * dns ([dnsStart], [dnsEnd])
 *    * connect ([connectStart], [connectEnd], [connectFailed])
 *      * secure connect ([secureConnectStart], [secureConnectEnd])
 *    * connection held ([connectionAcquired], [connectionReleased])
 *      * request ([requestFailed])

Plain Text

- Registered: Fri May 03 11:42:14 GMT 2024

- Last Modified: Mon Jan 08 01:13:22 GMT 2024

- 15.2K bytes

- Viewed (0)

github.com/istio/istio

istioctl/pkg/writer/compare/testdata/configdump_diff.json

      "version_info": "2024-03-04T08:37:44Z/4",
      "dynamic_listeners": [
        {
          "name": "connect_terminate",
          "active_state": {
            "listener": {
              "@type": "type.googleapis.com/envoy.config.listener.v3.Listener",
              "name": "connect_terminate",
              "address": {
                "socket_address": {
                  "address": "0.0.0.0",

Json

- Registered: Wed May 08 22:53:08 GMT 2024

- Last Modified: Tue Mar 12 10:02:09 GMT 2024

- 51.6K bytes

- Viewed (1)

github.com/google/guava

android/guava/src/com/google/common/graph/Network.java

  Graph<N> asGraph();

  //
  // Network properties
  //

  /**
   * Returns true if the edges in this network are directed. Directed edges connect a {@link
   * EndpointPair#source() source node} to a {@link EndpointPair#target() target node}, while
   * undirected edges connect a pair of nodes to each other.
   */
  boolean isDirected();

  /**

Java

- Registered: Fri Apr 26 12:43:10 GMT 2024

- Last Modified: Mon Jan 22 17:29:38 GMT 2024

- 21.1K bytes

- Viewed (0)

github.com/istio/istio

istioctl/pkg/writer/compare/testdata/configdump.json

      "version_info": "2024-03-04T08:37:44Z/4",
      "dynamic_listeners": [
        {
          "name": "connect_terminate",
          "active_state": {
            "listener": {
              "@type": "type.googleapis.com/envoy.config.listener.v3.Listener",
              "name": "connect_terminate",
              "address": {
                "socket_address": {
                  "address": "0.0.0.0",

Json

- Registered: Wed May 08 22:53:08 GMT 2024

- Last Modified: Tue Mar 12 10:02:09 GMT 2024

- 52K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/smb1/SmbSession.java

                /* Some pipes may require that the hostname in the tree connect
                 * be the netbios name. So if we have the netbios server name
                 * from the NTLMSSP type 2 message, and the share is IPC$, we
                 * assert that the tree connect path uses the netbios hostname.
                 */
                tcax.path = "\\\\" + netbiosName + "\\IPC$";

Java

- Registered: Sun May 05 00:10:10 GMT 2024

- Last Modified: Fri Mar 22 21:10:40 GMT 2019

- 18.6K bytes

- Viewed (0)

github.com/apache/maven

maven-core/src/test/resources/org/apache/maven/extension/test-extension-repo/org/apache/maven/wagon/wagon-provider-api/1.0-beta-2/wagon-provider-api-1.0-beta-2.jar

authentication.AuthenticationInfo getAuthenticationInf(); public void connect(repository.Repository) throws ConnectionException, authentication.AuthenticationExcept; public void connect(repository.Repository, proxy.ProxyInfo) throws ConnectionException, authentication.AuthenticationExcept; public void connect(repository.Repository, authentication.AuthenticationInfo) throws ConnectionException, authentication.AuthenticationExcept; public void connect(repository.Repository, authentication.AuthenticationInfo, proxy.ProxyInfo)...

src/test/java/org/codelibs/curl/io/IOIntegrationTest.java

    class MockCurlRequest extends CurlRequest {

        MockCurlRequest(Curl.Method method, String url) {
            super(method, url);
        }

        @Override
        public void connect(Consumer<HttpURLConnection> actionListener, Consumer<Exception> exceptionListener) {
            try {
                actionListener.accept(new MockHttpURLConnection(new URL(url)));
            } catch (MalformedURLException e) {

Java

- Registered: Thu May 09 15:34:10 GMT 2024

- Last Modified: Mon Nov 14 21:05:19 GMT 2022

- 3.4K bytes

- Viewed (0)

github.com/tiangolo/fastapi

tests/test_tutorial/test_websockets/test_tutorial001.py


def test_main():
    response = client.get("/")
    assert response.status_code == 200, response.text
    assert b"<!DOCTYPE html>" in response.content


def test_websocket():
    with pytest.raises(WebSocketDisconnect):
        with client.websocket_connect("/ws") as websocket:
            message = "Message one"
            websocket.send_text(message)
            data = websocket.receive_text()

Python

- Registered: Sun Apr 28 07:19:10 GMT 2024

- Last Modified: Fri Jul 10 09:08:19 GMT 2020

- 822 bytes

- Viewed (0)

github.com/minio/minio

internal/http/dial_linux.go

			_ = syscall.SetsockoptInt(fd, syscall.SOL_TCP, unix.TCP_FASTOPEN, 32*1024)

			// Enable TCP fast connect
			// TCPFastOpenConnect sets the underlying socket to use
			// the TCP fast open connect. This feature is supported
			// since Linux 4.11.
			_ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, unix.TCP_FASTOPEN_CONNECT, 1)

			// Enable TCP quick ACK, John Nagle says

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Wed Apr 24 04:08:47 GMT 2024

- 4.3K bytes

- Viewed (3)

Search Options