- Sort Score
- Result 10 results
- Languages All
Results 191 - 200 of 1,407 for responsive (0.13 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)