Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for hocontinuation (0.2 sec)

  1. okhttp-coroutines/src/main/kotlin/okhttp3/JvmCallExtensions.kt

    suspend fun Call.executeAsync(): Response =
      suspendCancellableCoroutine { continuation ->
        continuation.invokeOnCancellation {
          this.cancel()
        }
        this.enqueue(
          object : Callback {
            override fun onFailure(
              call: Call,
              e: IOException,
            ) {
              continuation.resumeWithException(e)
            }
    
            override fun onResponse(
              call: Call,
    Plain Text
    - Registered: Fri Apr 12 11:42:09 GMT 2024
    - Last Modified: Fri Apr 05 11:25:23 GMT 2024
    - 1.4K bytes
    - Viewed (0)
  2. okhttp-coroutines/src/main/kotlin/okhttp3/coroutines/ExecuteAsync.kt

    suspend fun Call.executeAsync(): Response =
      suspendCancellableCoroutine { continuation ->
        continuation.invokeOnCancellation {
          this.cancel()
        }
        this.enqueue(
          object : Callback {
            override fun onFailure(
              call: Call,
              e: IOException,
            ) {
              continuation.resumeWithException(e)
            }
    
            override fun onResponse(
              call: Call,
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Thu Apr 18 01:24:38 GMT 2024
    - 1.5K bytes
    - Viewed (0)
  3. .editorconfig

    root = true
    
    [*]
    indent_size = 2
    ij_continuation_indent_size = 2
    charset = utf-8
    trim_trailing_whitespace = true
    insert_final_newline = true
    
    [*.{kt, kts}]
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 185 bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt

      private fun readHeaderBlock(
        length: Int,
        padding: Int,
        flags: Int,
        streamId: Int,
      ): List<Header> {
        continuation.left = length
        continuation.length = continuation.left
        continuation.padding = padding
        continuation.flags = flags
        continuation.streamId = streamId
    
        // TODO: Concat multi-value headers with 0x0, except COOKIE, which uses 0x3B, 0x20.
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 19.9K bytes
    - Viewed (0)
  5. okhttp-android/src/main/baseline-prof.txt

    HSPLandroidx/lifecycle/LifecycleKt;->createCoroutineUnintercepted(Lkotlin/jvm/functions/Function2;Ljava/lang/Object;Lkotlin/coroutines/Continuation;)Lkotlin/coroutines/Continuation;
    HSPLandroidx/lifecycle/LifecycleKt;->intercepted(Lkotlin/coroutines/Continuation;)Lkotlin/coroutines/Continuation;
    HSPLandroidx/lifecycle/LifecycleOwnerKt;->getLifecycleScope(Landroidx/lifecycle/LifecycleOwner;)Landroidx/lifecycle/LifecycleCoroutineScope;
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Mar 21 11:22:00 GMT 2022
    - 127.9K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt

    import okhttp3.internal.http2.Http2.FLAG_END_STREAM
    import okhttp3.internal.http2.Http2.FLAG_NONE
    import okhttp3.internal.http2.Http2.INITIAL_MAX_FRAME_SIZE
    import okhttp3.internal.http2.Http2.TYPE_CONTINUATION
    import okhttp3.internal.http2.Http2.TYPE_DATA
    import okhttp3.internal.http2.Http2.TYPE_GOAWAY
    import okhttp3.internal.http2.Http2.TYPE_HEADERS
    import okhttp3.internal.http2.Http2.TYPE_PING
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 11.3K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/internal/ws/WebSocketReaderTest.kt

        }.also { expected ->
          assertThat(expected.message).isEqualTo("Unexpected rsv1 flag")
        }
      }
    
      @Test fun reservedFlag1IsUnsupportedForContinuationFrames() {
        data.write("c000".decodeHex()) // Empty continuation, flag 1 set.
        assertFailsWith<ProtocolException> {
          clientReaderWithCompression.processNextFrame()
        }.also { expected ->
          assertThat(expected.message).isEqualTo("Unexpected rsv1 flag")
        }
      }
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 14.4K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketProtocol.kt

       * bytes represent the length. If this value is [PAYLOAD_LONG], the next eight bytes
       * represent the length.
       */
      internal const val B1_MASK_LENGTH = 127
    
      internal const val OPCODE_CONTINUATION = 0x0
      internal const val OPCODE_TEXT = 0x1
      internal const val OPCODE_BINARY = 0x2
    
      internal const val OPCODE_CONTROL_CLOSE = 0x8
      internal const val OPCODE_CONTROL_PING = 0x9
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 4.8K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2.kt

      const val TYPE_GOAWAY = 0x7
      const val TYPE_WINDOW_UPDATE = 0x8
      const val TYPE_CONTINUATION = 0x9
    
      const val FLAG_NONE = 0x0
      const val FLAG_ACK = 0x1 // Used for settings and ping.
      const val FLAG_END_STREAM = 0x1 // Used for headers and data.
      const val FLAG_END_HEADERS = 0x4 // Used for headers and continuation.
      const val FLAG_END_PUSH_PROMISE = 0x4
      const val FLAG_PADDED = 0x8 // Used for headers and data.
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 5.7K bytes
    - Viewed (0)
  10. docs/changelogs/changelog_2x.md

     *  Fix: Always configure NPN headers. This fixes connectivity to
        `https://facebook.com` when SPDY and HTTP/2 are both disabled. Otherwise an
        unexpected NPN response is received and OkHttp crashes.
     *  Fix: Write continuation frames when HPACK data is larger than 16383 bytes.
     *  Fix: Don't drop uncaught exceptions thrown in async calls.
     *  Fix: Throw an exception eagerly when a request body is not legal. Previously
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Feb 06 02:19:09 GMT 2022
    - 26.6K bytes
    - Viewed (0)
Back to top