Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for EventSourceRecorder (0.12 sec)

  1. okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceRecorder.kt

    import okhttp3.Response
    import okhttp3.internal.platform.Platform
    import okhttp3.internal.platform.Platform.Companion.get
    import okhttp3.sse.EventSource
    import okhttp3.sse.EventSourceListener
    
    class EventSourceRecorder : EventSourceListener() {
      private val events = LinkedBlockingDeque<Any>()
      private var cancel = false
    
      fun enqueueCancel() {
        cancel = true
      }
    
      override fun onOpen(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  2. okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourcesHttpTest.kt

      @RegisterExtension
      val platform = PlatformRule()
      private lateinit var server: MockWebServer
    
      @RegisterExtension
      val clientTestRule = OkHttpClientTestRule()
    
      private val listener = EventSourceRecorder()
      private val client = clientTestRule.newClient()
    
      @BeforeEach
      fun before(server: MockWebServer) {
        this.server = server
      }
    
      @AfterEach
      fun after() {
        listener.assertExhausted()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Jan 14 10:20:09 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  3. okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceHttpTest.kt

      private lateinit var server: MockWebServer
    
      @RegisterExtension
      val clientTestRule = OkHttpClientTestRule()
      private val eventListener = RecordingEventListener()
      private val listener = EventSourceRecorder()
      private var client =
        clientTestRule.newClientBuilder()
          .eventListenerFactory(clientTestRule.wrap(eventListener))
          .build()
    
      @BeforeEach
      fun before(server: MockWebServer) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Jan 14 10:20:09 UTC 2024
    - 6.6K bytes
    - Viewed (0)
Back to top