- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 62 for Framer (0.39 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt
reason: String, ) } /** * Process the next protocol frame. * * * If it is a control frame this will result in a single call to [FrameCallback]. * * If it is a message frame this will result in a single call to [FrameCallback.onReadMessage]. * If the message spans multiple frames, each interleaved control frame will result in a * corresponding call to [FrameCallback]. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.8K bytes - Viewed (0) -
okhttp/src/test/resources/okhttp3/internal/publicsuffix/public_suffix_list.dat
// Submitted by Roderick Parr <******@****.***> forgeblocks.com id.forgerock.io // Framer : https://www.framer.com // Submitted by Koen Rouwhorst <koenrh@framer.com> framer.app framercanvas.com framer.media framer.photos framer.website framer.wiki // Frusky MEDIA&PR : https://www.frusky.de // Submitted by Victor Pupynin <******@****.***> *.frusky.de
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 240.3K bytes - Viewed (3) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
if (closed) return outFinished = errorCode == null } if (!sink.finished) { // We have 0 or more frames of data, and 0 or more frames of trailers. We need to send at // least one frame with the END_STREAM flag set. That must be the last frame, and the // trailers must be sent after all of the data. val hasData = sendBuffer.size > 0L val hasTrailers = trailers != null
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2.kt
import okio.ByteString.Companion.encodeUtf8 object Http2 { @JvmField val CONNECTION_PREFACE = "PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n".encodeUtf8() /** The initial max frame size, applied independently writing to, or reading from the peer. */ const val INITIAL_MAX_FRAME_SIZE = 0x4000 // 16384 const val TYPE_DATA = 0x0 const val TYPE_HEADERS = 0x1 const val TYPE_PRIORITY = 0x2 const val TYPE_RST_STREAM = 0x3
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) -
okhttp/src/main/kotlin/okhttp3/internal/http2/flowcontrol/WindowCounter.kt
class WindowCounter( val streamId: Int, ) { /** The total number of bytes consumed. */ var total: Long = 0L private set /** The total number of bytes acknowledged by outgoing `WINDOW_UPDATE` frames. */ var acknowledged: Long = 0L private set val unacknowledged: Long @Synchronized get() = total - acknowledged @Synchronized fun update( total: Long = 0, acknowledged: Long = 0,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Apr 05 03:30:42 GMT 2024 - 1.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/ConnectionShutdownException.kt
* limitations under the License. */ package okhttp3.internal.http2 import java.io.IOException /** * Thrown when an HTTP/2 connection is shutdown (either explicitly or if the peer has sent a GOAWAY * frame) and an attempt is made to use the connection. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 875 bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/ErrorCode.kt
/** Not an error! */ NO_ERROR(0), PROTOCOL_ERROR(1), INTERNAL_ERROR(2), FLOW_CONTROL_ERROR(3), SETTINGS_TIMEOUT(4), STREAM_CLOSED(5), FRAME_SIZE_ERROR(6), REFUSED_STREAM(7), CANCEL(8), COMPRESSION_ERROR(9), CONNECT_ERROR(0xa), ENHANCE_YOUR_CALM(0xb), INADEQUATE_SECURITY(0xc), HTTP_1_1_REQUIRED(0xd), ;
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.2K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/TestUtilJvm.kt
* structures. * * We make such subtle calls in [okhttp3.internal.ws.MessageInflater] because we try to read a * compressed stream that is terminated in a web socket frame even though the DEFLATE stream is * not terminated. * * Use this method to create a degenerate Okio Buffer where each byte is in a separate segment of * the internal list. */ @JvmStatic
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 4.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
import okio.ByteString import okio.Source import okio.Timeout /** * Reads HTTP/2 transport frames. * * This implementation assumes we do not send an increased [frame][Settings.getMaxFrameSize] to the * peer. Hence, we expect all frames to have a max length of [Http2.INITIAL_MAX_FRAME_SIZE]. */ class Http2Reader( /** Creates a frame reader with max header table size of 4096. */ private val source: BufferedSource,
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) -
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
// Note: we don't process server frames so our client 'close' doesn't receive a server 'close'. assertThat(client.canceled).isFalse() taskFaker.advanceUntil(ns(4_999)) assertThat(client.canceled).isFalse() taskFaker.advanceUntil(ns(5_000)) assertThat(client.canceled).isTrue() client.processNextFrame() // This won't get a frame, but it will get a closed pipe.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 01:59:58 GMT 2024 - 18.5K bytes - Viewed (0)