- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 78 for fwrite (0.14 sec)
-
okhttp/src/test/java/okhttp3/internal/ws/WebSocketReaderTest.kt
val bytes = binaryData(200) data.write("0264".decodeHex()).write(bytes, 0, 100) data.write("8064".decodeHex()).write(bytes, 100, 100) clientReader.processNextFrame() callback.assertBinaryMessage(bytes) } @Test fun twoFrameNotContinuation() { val bytes = binaryData(200) data.write("0264".decodeHex()).write(bytes, 0, 100) data.write("8264".decodeHex()).write(bytes, 100, 100)
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) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt
private var maxFrameSize: Int = INITIAL_MAX_FRAME_SIZE private var closed: Boolean = false val hpackWriter: Hpack.Writer = Hpack.Writer(out = hpackBuffer) @Throws(IOException::class) fun connectionPreface() { this.withLock { if (closed) throw IOException("closed") if (!client) return // Nothing to write; servers don't send connection headers! if (logger.isLoggable(FINE)) {
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) -
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
client.webSocket!!.close(1000, "Hello") server.processNextFrame() // Not closed until close reply is received. assertThat(client.closed).isFalse() // Manually write an invalid masked close frame. server.sink.write("888760b420bb635c68de0cd84f".decodeHex()).emit() client.processNextFrame() // Detects error, disconnects immediately since close already sent. client.webSocket!!.finishReader()
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) -
okhttp/src/test/java/okhttp3/internal/http2/HpackTest.kt
// Use a new Writer because we don't support change the dynamic table // size after Writer constructed. val writer = Hpack.Writer(110, false, bytesOut) writer.writeHeaders(headerBlock) assertThat(bytesOut).isEqualTo(bytesIn) assertThat(writer.headerCount).isEqualTo(2) val tableLength = writer.dynamicTable.size var entry = writer.dynamicTable[tableLength - 1]!!
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 38.2K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/Adapters.kt
bytes = bytes, ) } } override fun toDer( writer: DerWriter, value: AnyValue, ) { writer.write("ANY", value.tagClass, value.tag) { writer.writeOctetString(value.bytes) writer.constructed = value.constructed } } } internal fun parseGeneralizedTime(string: String): Long {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 15K bytes - Viewed (0) -
docs/en/docs/async.md
But if you want to use `async` / `await` without FastAPI, you can do it as well. ### Write your own async code
Plain Text - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Thu Apr 18 19:53:19 GMT 2024 - 23K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/CacheInterceptor.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Mar 22 07:09:21 GMT 2024 - 10.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
taskFaker.runTasks() } private fun connectHttp2( peer: MockHttp2Peer, realConnection: RealConnection, maxConcurrentStreams: Int, ): Http2Connection { // Write the mocking script. val settings1 = Settings() settings1[Settings.MAX_CONCURRENT_STREAMS] = maxConcurrentStreams peer.sendFrame().settings(settings1) peer.acceptFrame() // ACK
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 12.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RequestTest.kt
assertThat(bodyToHex(body), "Retransmit body").isEqualTo("48656c6c6f") } @Test fun file() { val file = File.createTempFile("RequestTest", "tmp") val writer = FileWriter(file) writer.write("abc") writer.close() val contentType = "text/plain".toMediaType() val body: RequestBody = file.asRequestBody(contentType) assertThat(body.contentType()).isEqualTo(contentType)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 16.4K bytes - Viewed (0) -
docs/ko/docs/tutorial/security/simple-oauth2.md
사양에는 클라이언트가 다른 폼 필드 "`scope`"를 보낼 수 있다고 나와 있습니다. 폼 필드 이름은 `scope`(단수형)이지만 실제로는 공백으로 구분된 "범위"가 있는 긴 문자열입니다. 각 "범위"는 공백이 없는 문자열입니다. 일반적으로 특정 보안 권한을 선언하는 데 사용됩니다. 다음을 봅시다: * `users:read` 또는 `users:write`는 일반적인 예시입니다. * `instagram_basic`은 페이스북/인스타그램에서 사용합니다. * `https://www.googleapis.com/auth/drive`는 Google에서 사용합니다. !!! 정보 OAuth2에서 "범위"는 필요한 특정 권한을 선언하는 문자열입니다. `:`과 같은 다른 문자가 있는지 또는 URL인지는 중요하지 않습니다.
Plain Text - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Tue Apr 02 22:37:23 GMT 2024 - 11.6K bytes - Viewed (0)