- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 59 for Kistner (0.29 sec)
-
okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceHttpTest.kt
).setHeader("content-type", "text/event-stream") .build(), ) val source = newEventSource() assertThat(source.request().url.encodedPath).isEqualTo("/") listener.assertOpen() listener.assertEvent(null, null, "hey") listener.assertClose() } @RetryingTest(5) fun cancelInEventShortCircuits() { server.enqueue( MockResponse.Builder() .body( """
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Jan 14 10:20:09 GMT 2024 - 6.6K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/internal/RealEventSource.kt
listener.onFailure(this, IOException("canceled"), response) } else { listener.onClosed(this) } } } private fun ResponseBody.isEventStream(): Boolean { val contentType = contentType() ?: return false return contentType.type == "text" && contentType.subtype == "event-stream" } override fun onFailure( call: Call, e: IOException, ) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.2K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/EventSourceListener.kt
) { } /** * TODO description. * * No further calls to this listener will be made. */ open fun onClosed(eventSource: EventSource) { } /** * Invoked when an event source has been closed due to an error reading from or writing to the * network. Incoming events may have been lost. No further calls to this listener will be made. */ open fun onFailure( eventSource: EventSource,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.5K bytes - Viewed (1) -
okhttp/src/test/java/okhttp3/DuplexTest.kt
var clientTestRule = OkHttpClientTestRule() private lateinit var server: MockWebServer private var listener = RecordingEventListener() private val handshakeCertificates = platform.localhostHandshakeCertificates() private var client = clientTestRule.newClientBuilder() .eventListenerFactory(clientTestRule.wrap(listener)) .build() private val executorService = Executors.newScheduledThreadPool(1) @BeforeEach
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 23.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/AutobahnTester.kt
*/ class AutobahnTester { val client = OkHttpClient() private fun newWebSocket( path: String, listener: WebSocketListener, ): WebSocket { val request = Request.Builder() .url(HOST + path) .build() return client.newWebSocket(request, listener) } fun run() { try { val count = getTestCount() println("Test count: $count")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.6K bytes - Viewed (0) -
native-image-tests/src/main/kotlin/okhttp3/RunTests.kt
return discovered.getEngineTestDescriptor(testEngine).descendants.toList() } /** * Builds the awkwardly package private TreePrintingListener listener which we would like to use * from ConsoleLauncher. * * https://github.com/junit-team/junit5/issues/2469 */ fun treeListener(): TestExecutionListener { val colorPalette =
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.3K bytes - Viewed (0) -
docs/en/docs/tutorial/cookie-params.md
!!! tip Prefer to use the `Annotated` version if possible. ```Python hl_lines="9" {!> ../../../docs_src/cookie_params/tutorial001.py!} ``` !!! note "Technical Details" `Cookie` is a "sister" class of `Path` and `Query`. It also inherits from the same common `Param` class. But remember that when you import `Query`, `Path`, `Cookie` and others from `fastapi`, those are actually functions that return special classes.
Plain Text - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Tue Oct 17 05:59:11 GMT 2023 - 2.4K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
val http2SocketHandler = Http2SocketHandler(socket, protocol) val connection = Http2Connection.Builder(false, taskRunner) .socket(socket) .listener(http2SocketHandler) .build() connection.start() openConnections.add(connection) openClientSockets.remove(socket) return } else if (protocol !== Protocol.HTTP_1_1) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 37.4K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/WiresharkExample.kt
* * Steps to run in your own code * * 1. In your main method `WireSharkListenerFactory.register()` * 2. Create Listener factory `val eventListenerFactory = WireSharkListenerFactory( logFile = File("/tmp/key.log"), tlsVersions = tlsVersions, launch = launch)` * 3. Register with `client.eventListenerFactory(eventListenerFactory)`
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.7K bytes - Viewed (1) -
architecture/environments/operator.md
`IstioOperatorSpec` has pass-through fields to the Helm values.yaml API, but these are additionally validated through a [schema](../operator/pkg/apis/istio/v1alpha1/values_types.proto). 1. [Controller](#k8s-controller) code. The code comprises the K8s listener, webhook and logic for reconciling the cluster to an `IstioOperatorSpec` CR. 1. [Manifest creation](#manifest-creation) code. User settings are overlaid on top of the
Plain Text - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed Aug 09 22:09:18 GMT 2023 - 13.4K bytes - Viewed (0)