Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for processNextEvent (0.05 sec)

  1. okhttp-sse/src/main/kotlin/okhttp3/sse/internal/ServerSentEventReader.kt

       * data section was empty. Any number of calls to [Callback.onRetryChange] may occur while
       * processing an event.
       *
       * @return false when EOF is reached
       */
      @Throws(IOException::class)
      fun processNextEvent(): Boolean {
        var id = lastId
        var type: String? = null
        val data = Buffer()
    
        while (true) {
          when (source.select(options)) {
            in 0..2 -> {
              completeEvent(id, type, data)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 11:47:47 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  2. okhttp-sse/src/main/kotlin/okhttp3/sse/internal/RealEventSource.kt

          val reader = ServerSentEventReader(body.source(), this)
          try {
            if (!canceled) {
              listener.onOpen(this, response)
              while (!canceled && reader.processNextEvent()) {
              }
            }
          } catch (e: Exception) {
            val exception =
              when {
                canceled -> IOException("canceled", e)
                else -> e
              }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 11:47:47 UTC 2025
    - 3.3K bytes
    - Viewed (0)
Back to top