- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 53 for event (0.64 sec)
-
okhttp-sse/src/test/java/okhttp3/sse/internal/Event.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3.sse.internal internal data class Event( val id: String?, val type: String?, val data: String,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Dec 23 10:26:25 GMT 2023 - 720 bytes - Viewed (0) -
docs/features/events.md
![Events Diagram](../assets/images/events@2x.png) 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
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 7.7K bytes - Viewed (0) -
okhttp-sse/src/test/java/okhttp3/sse/internal/ServerSentEventIteratorTest.kt
} @Test fun idCleared() { consumeEvents( """ |data: first event |id: 1 | |data: second event |id | |data: third event | | """.trimMargin(), ) assertThat(callbacks.remove()).isEqualTo(Event("1", null, "first event"))
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.4K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt
throw AssertionError("full event sequence: $fullEventSequence", e) } } /** * Remove and return the next event from the recorded sequence. * * @param eventClass a class to assert that the returned event is an instance of, or null to * take any event class. * @param elapsedMs the time in milliseconds elapsed since the immediately-preceding event, or * -1L to take any duration. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.6K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/EventSource.kt
/** Returns the original request that initiated this event source. */ fun request(): Request /** * Immediately and violently release resources held by this event source. This does nothing if * the event source has already been closed or canceled. */ fun cancel() fun interface Factory { /** * Creates a new event source and immediately returns it. Creating an event source initiates an
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.4K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/internal/ServerSentEventReader.kt
// 11 "id\r".encodeUtf8(), // 12 "id\n".encodeUtf8(), // 13 "event: ".encodeUtf8(), // 14 "event:".encodeUtf8(), // 15 "event\r\n".encodeUtf8(), // 16 "event\r".encodeUtf8(), // 17 "event\n".encodeUtf8(), // 18 "retry: ".encodeUtf8(), // 19 "retry:".encodeUtf8(),
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.3K bytes - Viewed (0) -
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 May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:18:15 GMT 2024 - 1.6K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/Authenticator.kt
* [RFC 2817][1]. The HTTP CONNECT request that creates this tunnel connection is special: it * does not participate in any [interceptors][Interceptor] or [event listeners][EventListener]. It * doesn't include the motivating request's HTTP headers or even its full URL; only the target * server's hostname is sent to the proxy. * * Prior to sending any CONNECT request OkHttp always calls the proxy authenticator so that it may
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketRecorder.kt
} fun assertExhausted() { assertThat(events).isEmpty() } fun assertOpen(): WebSocket { val event = nextEvent() as Open return event.webSocket } fun assertFailure(t: Throwable?) { val event = nextEvent() as Failure assertThat(event.response).isNull() assertThat(event.t).isSameAs(t) } fun assertFailure(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.9K bytes - Viewed (0) -
okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceRecorder.kt
} fun assertEvent( id: String?, type: String?, data: String, ) { assertThat(nextEvent()).isEqualTo(Event(id, type, data)) } fun assertOpen(): EventSource { val event = nextEvent() as Open return event.eventSource } fun assertClose() { nextEvent() as Closed } fun assertFailure(message: String?) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.1K bytes - Viewed (0)