Search Options

Results per page
Sort
Preferred Languages
Advance

Results 191 - 200 of 1,407 for responsive (0.13 sec)

  1. okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceRecorder.kt

        events.add(Closed)
        drainCancelQueue(eventSource)
      }
    
      override fun onFailure(
        eventSource: EventSource,
        t: Throwable?,
        response: Response?,
      ) {
        get().log("[ES] onFailure", Platform.INFO, t)
        events.add(Failure(t, response, t?.message ?: response?.body?.string()))
        drainCancelQueue(eventSource)
      }
    
      private fun drainCancelQueue(eventSource: EventSource) {
        if (cancel) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 11:32:52 UTC 2025
    - 3.2K bytes
    - Viewed (0)
  2. okhttp-sse/src/main/kotlin/okhttp3/sse/EventSources.kt

        replaceWith =
          ReplaceWith(
            expression = "response.processEventSource(listener)",
            imports = ["okhttp3.sse.EventSource.Companion.processEventSource"],
          ),
        level = DeprecationLevel.WARNING,
      )
      @JvmStatic
      fun processResponse(
        response: Response,
        listener: EventSourceListener,
      ): Unit = response.processEventSource(listener)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 11:47:47 UTC 2025
    - 1.8K bytes
    - Viewed (0)
  3. samples/guide/src/main/java/okhttp3/recipes/PerCallSettings.java

        OkHttpClient client1 = client.newBuilder()
            .readTimeout(500, TimeUnit.MILLISECONDS)
            .build();
        try (Response response = client1.newCall(request).execute()) {
          System.out.println("Response 1 succeeded: " + response);
        } catch (IOException e) {
          System.out.println("Response 1 failed: " + e);
        }
    
        // Copy to customize OkHttp for this request.
        OkHttpClient client2 = client.newBuilder()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun May 22 01:29:42 UTC 2016
    - 1.9K bytes
    - Viewed (0)
  4. src/test/java/jcifs/internal/smb2/ioctl/SrvRequestResumeKeyResponseTest.java

    import jcifs.internal.SMBProtocolDecodingException;
    
    /**
     * Test class for SrvRequestResumeKeyResponse
     */
    class SrvRequestResumeKeyResponseTest {
    
        private SrvRequestResumeKeyResponse response;
    
        @BeforeEach
        void setUp() {
            response = new SrvRequestResumeKeyResponse();
        }
    
        @Test
        @DisplayName("Test successful decode with valid resume key")
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 8.9K bytes
    - Viewed (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketHttpTest.kt

                assertThat(chain.request().body).isNull()
                val response = chain.proceed(chain.request())
                assertThat(response.header("Connection")).isEqualTo("Upgrade")
                assertThat(response.body).isInstanceOf<UnreadableResponseBody>()
                interceptedCount.incrementAndGet()
                response
              },
            ).build()
        webServer.enqueue(
          MockResponse
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 35.5K bytes
    - Viewed (0)
  6. src/test/java/org/codelibs/fess/suggest/SuggesterTest.java

            suggester.refresh();
    
            SuggestResponse response = suggester.suggest().setQuery("kensaku").setSuggestDetail(true).execute().getResponse();
            assertEquals(1, response.getNum());
            assertEquals("検索 エンジン", response.getWords().get(0));
    
            response = suggester.suggest().setQuery("kensaku  enj").execute().getResponse();
            assertEquals(1, response.getNum());
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 37.2K bytes
    - Viewed (0)
  7. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

      private fun writeHttpResponse(
        socket: MockWebServerSocket,
        response: MockResponse,
      ) {
        socket.sleepWhileOpen(response.headersDelayNanos)
        socket.sink.writeUtf8(response.status)
        socket.sink.writeUtf8("\r\n")
    
        writeHeaders(socket.sink, response.headers)
    
        if (response.socketHandler != null) {
          response.socketHandler.handle(socket)
          return
        }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 02 20:36:00 UTC 2025
    - 40.3K bytes
    - Viewed (0)
  8. src/test/java/jcifs/smb1/smb1/SmbComReadAndXResponseTest.java

            assertEquals(b, response.b);
            assertEquals(0, response.off);
        }
    
        @Test
        public void testSetParam() {
            byte[] b = new byte[0];
            response.setParam(b, 0);
            assertEquals(b, response.b);
            assertEquals(0, response.off);
        }
    
        @Test
        public void testWriteParameterWordsWireFormat() {
            assertEquals(0, response.writeParameterWordsWireFormat(new byte[0], 0));
        }
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 3.3K bytes
    - Viewed (0)
  9. okhttp/src/jvmTest/kotlin/okhttp3/OpenJSSETest.kt

        val request = Request(server.url("/"))
    
        val response = client.newCall(request).execute()
    
        response.use {
          assertEquals(200, response.code)
          assertEquals(TlsVersion.TLS_1_3, response.handshake?.tlsVersion)
          assertEquals(Protocol.HTTP_2, response.protocol)
    
          assertThat(response.exchangeAccessor!!.connectionAccessor.socket())
            .isInstanceOf<SSLSocketImpl>()
        }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 3.7K bytes
    - Viewed (0)
  10. okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/HttpLoggingInterceptor.kt

          val responseBody = response.body!!
          val contentLength = responseBody.contentLength()
          val bodySize = if (contentLength != -1L) "$contentLength-byte" else "unknown-length"
          logger.log(
            buildString {
              append("<-- ${response.code}")
              if (response.message.isNotEmpty()) append(" ${response.message}")
              append(" ${redactUrl(response.request.url)} (${tookMs}ms")
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Aug 21 14:27:04 UTC 2025
    - 11.4K bytes
    - Viewed (0)
Back to top