Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 457 for Observer (3.41 sec)

  1. okhttp-hpacktests/src/test/java/okhttp3/internal/http2/HpackDecodeTestBase.kt

        }
    
        /**
         * Checks if `expected` and `observed` are equal when viewed as a set and headers are
         * deduped.
         *
         * TODO: See if duped headers should be preserved on decode and verify.
         */
        private fun assertSetEquals(
          message: String,
          expected: List<Header>,
          observed: List<Header>,
        ) {
          assertThat(LinkedHashSet(observed), message)
            .isEqualTo(LinkedHashSet(expected))
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 2.2K bytes
    - Viewed (0)
  2. mockwebserver/src/test/java/mockwebserver3/MockResponseSniTest.kt

      val platform = PlatformRule()
    
      private lateinit var server: MockWebServer
    
      @BeforeEach
      fun setUp(server: MockWebServer) {
        this.server = server
      }
    
      @Test
      fun clientSendsServerNameAndServerReceivesIt() {
        // java.net.ConnectException: Connection refused
        platform.assumeNotConscrypt()
    
        val handshakeCertificates = localhost()
        server.useHttps(handshakeCertificates.sslSocketFactory())
    
    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)
  3. okhttp/src/test/java/okhttp3/ServerTruncatesRequestTest.kt

      private var client =
        clientTestRule.newClientBuilder()
          .eventListenerFactory(clientTestRule.wrap(listener))
          .build()
    
      private lateinit var server: MockWebServer
    
      @BeforeEach
      fun setUp(server: MockWebServer) {
        this.server = server
        platform.assumeNotOpenJSSE()
        platform.assumeHttp2Support()
      }
    
      @Test
      fun serverTruncatesRequestOnLongPostHttp1() {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 9.5K bytes
    - Viewed (0)
  4. mockwebserver/README.md

      // instance for every unit test.
      MockWebServer server = new MockWebServer();
    
      // Schedule some responses.
      server.enqueue(new MockResponse().setBody("hello, world!"));
      server.enqueue(new MockResponse().setBody("sup, bra?"));
      server.enqueue(new MockResponse().setBody("yo dog"));
    
      // Start the server.
      server.start();
    
      // Ask the server for its URL. You'll need this to make HTTP requests.
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Dec 17 15:34:10 GMT 2023
    - 5K bytes
    - Viewed (1)
  5. docs/en/docs/deployment/manually.md

    * <a href="https://pgjones.gitlab.io/hypercorn/" class="external-link" target="_blank">Hypercorn</a>: an ASGI server compatible with HTTP/2 and Trio among other features.
    * <a href="https://github.com/django/daphne" class="external-link" target="_blank">Daphne</a>: the ASGI server built for Django Channels.
    
    ## Server Machine and Server Program
    
    Plain Text
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Thu May 02 22:37:31 GMT 2024
    - 9.2K bytes
    - Viewed (0)
  6. docs/multi-tenancy/README.md

    To host multiple tenants on a single machine, run one MinIO Server per tenant with a dedicated HTTPS port, configuration, and data directory.
    
    ### 1.1 Host Multiple Tenants on a Single Drive
    
    Use the following commands to host 3 tenants on a single drive:
    
    ```sh
    minio server --address :9001 /data/tenant1
    minio server --address :9002 /data/tenant2
    minio server --address :9003 /data/tenant3
    ```
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Sep 29 04:28:45 GMT 2022
    - 3K bytes
    - Viewed (0)
  7. maven-compat/src/test/java/org/apache/maven/repository/legacy/LegacyRepositorySystemTest.java

            assertEquals(basedir, new File(repo.getBasedir()));
        }
    
        @Test
        void testAuthenticationHandling() {
            Server server = new Server();
            server.setId("repository");
            server.setUsername("jason");
            server.setPassword("abc123");
    
            ArtifactRepository repository =
                    repositorySystem.createArtifactRepository("repository", "http://foo", null, null, null);
    Java
    - Registered: Sun May 05 03:35:11 GMT 2024
    - Last Modified: Thu Apr 25 05:46:50 GMT 2024
    - 2.4K bytes
    - Viewed (0)
  8. tensorflow/c/eager/parallel_device/parallel_device_remote_test.cc

    #include "tensorflow/core/distributed_runtime/rpc/grpc_server_lib.h"
    #include "tensorflow/core/platform/test.h"
    
    tensorflow::ServerDef GetServerDef(const std::string& job_name, int num_tasks) {
      tensorflow::ServerDef server_def;
      server_def.set_protocol("grpc");
      server_def.set_job_name(job_name);
      server_def.set_task_index(0);
      tensorflow::ClusterDef* cluster_def = server_def.mutable_cluster();
    C++
    - Registered: Tue Apr 30 12:39:09 GMT 2024
    - Last Modified: Thu Apr 27 22:09:57 GMT 2023
    - 6.7K bytes
    - Viewed (0)
  9. okhttp/src/test/java/okhttp3/OpenJSSETest.kt

      var client = clientTestRule.newClient()
    
      private lateinit var server: MockWebServer
    
      @BeforeEach
      fun setUp(server: MockWebServer) {
        this.server = server
        platform.assumeOpenJSSE()
      }
    
      @Test
      fun testTlsv13Works() {
        enableTls()
    
        server.enqueue(MockResponse(body = "abc"))
    
        val request = Request(server.url("/"))
    
        val response = client.newCall(request).execute()
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Jan 20 10:30:28 GMT 2024
    - 3.7K bytes
    - Viewed (0)
  10. okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceHttpTest.kt

          .eventListenerFactory(clientTestRule.wrap(eventListener))
          .build()
    
      @BeforeEach
      fun before(server: MockWebServer) {
        this.server = server
      }
    
      @AfterEach
      fun after() {
        listener.assertExhausted()
      }
    
      @Test
      fun event() {
        server.enqueue(
          MockResponse.Builder()
            .body(
              """
              |data: hey
              |
              |
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Jan 14 10:20:09 GMT 2024
    - 6.6K bytes
    - Viewed (0)
Back to top