- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for Grieger (0.17 sec)
-
docs/features/events.md
![Events Diagram](../assets/images/******@****.***) ### Availability
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 7.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/URLConnectionTest.kt
body = "abc", socketPolicy = DisconnectAtEnd, ), ) server.enqueue( MockResponse(body = "def"), ) // Send a separate request which will trigger a GOAWAY frame on the healthy connection. val response = getResponse(newRequest("/")) assertContent("abc", response) // Ensure the GOAWAY frame has time to be read and processed. Thread.sleep(500)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 131.7K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/WebSocketEcho.java
.build(); Request request = new Request.Builder() .url("ws://echo.websocket.org") .build(); client.newWebSocket(request, this); // Trigger shutdown of the dispatcher's executor so this process exits immediately. client.dispatcher().executorService().shutdown(); } @Override public void onOpen(WebSocket webSocket, Response response) {
Java - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Apr 04 11:40:21 GMT 2024 - 1.6K bytes - Viewed (0) -
docs/changelogs/changelog_2x.md
## Version 2.4.0 _2015-05-22_ * **Forbid response bodies on HTTP 204 and 205 responses.** Webservers that return such malformed responses will now trigger a `ProtocolException` in the client. * **WebSocketListener has incompatible changes.** The `onOpen()` method is now called on the reader thread, so implementations must return before further
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 26.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/ResponseBody.kt
abstract fun source(): BufferedSource /** * Returns the response as a byte array. * * This method loads entire response body into memory. If the response body is very large this * may trigger an [OutOfMemoryError]. Prefer to stream the response body if this is a * possibility for your response. */ @Throws(IOException::class) fun bytes() = commonBytes() /**
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/DispatcherTest.kt
dispatcher.maxRequests = 1 client.newCall(request1).enqueue(callback) executor.shutdown() client.newCall(request2).enqueue(callback) dispatcher.maxRequests = 2 // Trigger promotion. callback.await(request2.url).assertFailure(InterruptedIOException::class.java) assertThat(listener.recordedEventTypes()) .containsExactly("CallStart", "CallStart", "CallFailed") } @Test
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Fri Apr 05 03:30:42 GMT 2024 - 12.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/platform/OpenJSSEPlatform.kt
null, "" -> null else -> protocol } } else { super.getSelectedProtocol(sslSocket) } companion object { val isSupported: Boolean = try { // Trigger an early exception over a fatal error, prefer a RuntimeException over Error. Class.forName("org.openjsse.net.ssl.OpenJSSE", false, javaClass.classLoader) true } catch (_: ClassNotFoundException) {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt
} // Cause the rebuild action to fail. filesystem.setFaultyRename( cacheDir / DiskLruCache.JOURNAL_FILE_BACKUP, true, ) taskFaker.runNextTask() // Trigger a job to trim the cache. cache.maxSize = 4 taskFaker.runNextTask() assertAbsent("a") assertValue("b", "bb", "bb") } @ParameterizedTest
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Apr 15 14:55:09 GMT 2024 - 75.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
taskFaker.runTasks() server.webSocket!!.tearDown() client.webSocket!!.tearDown() taskFaker.close() } @Test fun close() { client.webSocket!!.close(1000, "Hello!") // This will trigger a close response. assertThat(server.processNextFrame()).isFalse() server.listener.assertClosing(1000, "Hello!") server.webSocket!!.finishReader() server.webSocket!!.close(1000, "Goodbye!")
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Apr 11 01:59:58 GMT 2024 - 18.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
streamId: Int, source: BufferedSource, length: Int, ) /** * Create or update incoming headers, creating the corresponding streams if necessary. Frames * that trigger this are HEADERS and PUSH_PROMISE. * * @param inFinished true if the sender will not send further frames. * @param streamId the stream owning these headers.
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 19.9K bytes - Viewed (0)