Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 18 for hocontinuation (0.22 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/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 Apr 26 11:42:10 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 5.7K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt

            }
          }
    
          if (isFinalFrame) break // We are exhausted and have no continuations.
    
          readUntilNonControlFrame()
          if (opcode != OPCODE_CONTINUATION) {
            throw ProtocolException("Expected continuation opcode. Got: ${opcode.toHexString()}")
          }
        }
      }
    
      @Throws(IOException::class)
      override fun close() {
        messageInflater?.close()
      }
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 9.8K bytes
    - Viewed (0)
  4. analysis/analysis-api-fe10/src/org/jetbrains/kotlin/analysis/api/descriptors/utils/KtFe10TypeSystemCommonBackendContextForTypeMapping.kt

            val continuationFqName = StandardClassIds.Continuation.asSingleFqName()
            val foundClasses = resolveSession.getTopLevelClassifierDescriptors(continuationFqName, NoLookupLocation.FROM_IDE)
            return foundClasses.firstOrNull()?.typeConstructor
                ?: FAKE_CONTINUATION_CLASS_DESCRIPTOR.typeConstructor
        }
    
    Plain Text
    - Registered: Fri Apr 26 08:18:10 GMT 2024
    - Last Modified: Fri Feb 10 16:01:04 GMT 2023
    - 5.6K bytes
    - Viewed (0)
  5. docs/en/docs/release-notes.md

    * ✨ Support `dataclasses` in responses. PR [#3576](https://github.com/tiangolo/fastapi/pull/3576) by [@tiangolo](https://github.com/tiangolo), continuation from initial PR [#2722](https://github.com/tiangolo/fastapi/pull/2722) by [@amitlissack](https://github.com/amitlissack).
    
    ### Docs
    
    Plain Text
    - Registered: Sun Apr 28 07:19:10 GMT 2024
    - Last Modified: Sun Apr 28 00:28:00 GMT 2024
    - 385.5K bytes
    - Viewed (1)
  6. okhttp/src/test/java/okhttp3/internal/http2/FrameLogTest.kt

      fun flagOverlapOn0x4() {
        assertThat(frameLog(true, 3, 10000, TYPE_HEADERS, 0x4))
          .isEqualTo("<< 0x00000003 10000 HEADERS       END_HEADERS")
        assertThat(frameLog(true, 3, 10000, TYPE_CONTINUATION, 0x4))
          .isEqualTo("<< 0x00000003 10000 CONTINUATION  END_HEADERS")
        assertThat(frameLog(true, 4, 10000, TYPE_PUSH_PROMISE, 0x4))
          .isEqualTo("<< 0x00000004 10000 PUSH_PROMISE  END_PUSH_PROMISE")
      }
    
      @Test
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 5.9K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/internal/http2/Http2Test.kt

        frame.writeInt(expectedStreamId and 0x7fffffff)
        frame.write(headerBlock, Http2.INITIAL_MAX_FRAME_SIZE.toLong())
    
        // Write the continuation frame, specifying no more frames are expected.
        writeMedium(frame, headerBlock.size.toInt())
        frame.writeByte(Http2.TYPE_CONTINUATION)
        frame.writeByte(FLAG_END_HEADERS)
        frame.writeInt(expectedStreamId and 0x7fffffff)
        frame.writeAll(headerBlock)
    
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 28.1K bytes
    - Viewed (0)
  8. okhttp-coroutines/api/okhttp-coroutines.api

    public final class okhttp3/coroutines/ExecuteAsyncKt {
    	public static final fun executeAsync (Lokhttp3/Call;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Thu Apr 18 01:24:38 GMT 2024
    - 163 bytes
    - Viewed (0)
  9. okhttp-idna-mapping-table/src/main/resources/okhttp3/internal/idna/IdnaMappingTable.txt

    111DB         ; valid                  ;      ; NV8    # 8.0  SHARADA SIGN SIDDHAM
    111DC         ; valid                                  # 8.0  SHARADA HEADSTROKE
    111DD..111DF  ; valid                  ;      ; NV8    # 8.0  SHARADA CONTINUATION SIGN..SHARADA SECTION MARK-2
    111E0         ; disallowed                             # NA   <reserved-111E0>
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Sat Feb 10 11:25:47 GMT 2024
    - 854.1K bytes
    - Viewed (2)
  10. 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 Apr 26 11:42:10 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 19.9K bytes
    - Viewed (0)
Back to top