- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 50 for Kistner (0.16 sec)
-
okhttp-sse/src/main/kotlin/okhttp3/sse/EventSources.kt
return EventSource.Factory { request, listener -> val actualRequest = if (request.header("Accept") == null) { request.newBuilder().addHeader("Accept", "text/event-stream").build() } else { request } RealEventSource(actualRequest, listener).apply { connect(callFactory) } } } @JvmStatic
Plain Text - Registered: Fri Apr 19 11:42:09 GMT 2024 - Last Modified: Sat Apr 06 04:18:15 GMT 2024 - 1.6K bytes - Viewed (1) -
docs/features/events.md
![Events Diagram](../assets/images/******@****.***) Here’s a [sample event listener](https://github.com/square/okhttp/blob/master/samples/guide/src/main/java/okhttp3/recipes/PrintEventsNonConcurrent.java) that prints each event with a timestamp. ```java class PrintingEventListener extends EventListener {
Plain Text - Registered: Fri Apr 19 11:42:09 GMT 2024 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 7.7K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/EventSource.kt
* asynchronous process to connect the socket. Once that succeeds or fails, `listener` will be * notified. The caller must cancel the returned event source when it is no longer in use. */ fun newEventSource( request: Request, listener: EventSourceListener, ): EventSource }
Plain Text - Registered: Fri Apr 19 11:42:09 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ServerTruncatesRequestTest.kt
@RegisterExtension @JvmField var clientTestRule = OkHttpClientTestRule() private val listener = RecordingEventListener() private val handshakeCertificates = platform.localhostHandshakeCertificates() private var client = clientTestRule.newClientBuilder() .eventListenerFactory(clientTestRule.wrap(listener)) .build() private lateinit var server: MockWebServer @BeforeEach
Plain Text - Registered: Fri Apr 19 11:42:09 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.5K bytes - Viewed (0) -
samples/slack/src/main/java/okhttp3/slack/SlackApi.java
} } /** See https://api.slack.com/rtm. */ public WebSocket rtm(HttpUrl url, WebSocketListener listener) { return httpClient.newWebSocket(new Request.Builder() .url(url) .build(), listener); } static final class SlackJsonAdapters { @ToJson String urlToJson(HttpUrl httpUrl) { return httpUrl.toString(); }
Java - Registered: Fri Apr 19 11:42:09 GMT 2024 - Last Modified: Fri Jul 06 19:30:55 GMT 2018 - 4.4K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
private var protocol: Protocol?, private var source: BufferedSource?, private var sink: BufferedSink?, private val pingIntervalMillis: Int, internal val connectionListener: ConnectionListener, ) : Http2Connection.Listener(), Connection, ExchangeCodec.Carrier { private var http2Connection: Http2Connection? = null // These properties are guarded by this. /**
Plain Text - Registered: Fri Apr 19 11:42:09 GMT 2024 - Last Modified: Wed Apr 17 05:15:48 GMT 2024 - 15.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
* [requestBodyOpen], [responseBodyOpen], and [expectMoreExchanges]. * * This will release the connection if it is still held. * * It will also notify the listener that the call completed; either successfully or * unsuccessfully. * * If the call was canceled or timed out, this will wrap [e] in an exception that provides that
Plain Text - Registered: Fri Apr 19 11:42:09 GMT 2024 - Last Modified: Wed Apr 17 05:15:48 GMT 2024 - 17.8K bytes - Viewed (2) -
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
server.processNextFrame() client.listener.assertClosing(1000, "Hello!") server.listener.assertClosing(1000, "Hi!") client.webSocket!!.finishReader() server.webSocket!!.finishReader() client.listener.assertClosed(1000, "Hello!") server.listener.assertClosed(1000, "Hi!") taskFaker.runTasks() assertThat(client.closed).isTrue()
Plain Text - Registered: Fri Apr 19 11:42:09 GMT 2024 - Last Modified: Thu Apr 11 01:59:58 GMT 2024 - 18.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/FastFallbackTest.kt
// In the process we made one successful connection attempt. assertThat(listener.recordedEventTypes().filter { it == "ConnectStart" }).hasSize(2) assertThat(listener.recordedEventTypes().filter { it == "ConnectFailed" }).hasSize(1) assertThat(listener.recordedEventTypes().filter { it == "ConnectEnd" }).hasSize(1) } @Test fun reachesIpv6WhenIpv4IsDown() {
Plain Text - Registered: Fri Apr 19 11:42:09 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/CacheInterceptor.kt
.build().also { listener.satisfactionFailure(call, it) } } // If we don't need the network, we're done. if (networkRequest == null) { return cacheResponse!!.newBuilder() .cacheResponse(cacheResponse.stripBody()) .build().also { listener.cacheHit(call, it) } } if (cacheResponse != null) {
Plain Text - Registered: Fri Apr 19 11:42:09 GMT 2024 - Last Modified: Fri Mar 22 07:09:21 GMT 2024 - 10.2K bytes - Viewed (0)