- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 60 for Flush (0.17 sec)
-
okhttp/src/test/java/okhttp3/DuplexTest.kt
requestBody.flush() val responseBody = response.body.source() assertThat(responseBody.readUtf8Line()) .isEqualTo("response B") requestBody.writeUtf8("request C\n") requestBody.flush() assertThat(responseBody.readUtf8Line()) .isEqualTo("response D") requestBody.writeUtf8("request E\n") requestBody.flush()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 23.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
} } @Throws(IOException::class) override fun flush() { lock.assertNotHeld() ******@****.***ck { checkOutNotClosed() } // TODO(jwilson): flush the connection?! while (sendBuffer.size > 0L) { emitFrame(false) connection.flush() } } override fun timeout(): Timeout = writeTimeout
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/Http2Writer.kt
if (byteCount > length) writeContinuationFrames(streamId, byteCount - length) } } @Throws(IOException::class) fun flush() { this.withLock { if (closed) throw IOException("closed") sink.flush() } } @Throws(IOException::class) fun rstStream( streamId: Int, errorCode: ErrorCode, ) { this.withLock {
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/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt
cleanupQueue.schedule(cleanupTask) return null } // Flush the journal before creating files to prevent file leaks. val journalWriter = this.journalWriter!! journalWriter.writeUtf8(DIRTY) .writeByte(' '.code) .writeUtf8(key) .writeByte('\n'.code) journalWriter.flush() if (hasJournalErrors) { return null // Don't edit; the journal can't be written.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 34.7K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/JsseDebugLogging.kt
override fun publish(record: LogRecord) { val param = record.parameters?.firstOrNull() as? String debugHandler(JsseDebugMessage(record.message, param)) } override fun flush() { } override fun close() { } }, ) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/ThreadInterruptTest.kt
override fun contentType() = null override fun writeTo(sink: BufferedSink) { for (i in 0..9) { sink.writeByte(0) sink.flush() sleep(100) } fail("Expected connection to be closed") } }, ) .build(), ) interruptLater(500)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.6K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/internal/ThrottledSink.kt
override fun write( source: Buffer, byteCount: Long, ) { var bytesLeft = byteCount while (bytesLeft > 0) { if (bytesWrittenSinceLastDelay == bytesPerPeriod) { flush() sleepNanos(periodDelayNanos) bytesWrittenSinceLastDelay = 0 } val toWrite = minOf(bytesLeft, bytesPerPeriod - bytesWrittenSinceLastDelay) bytesWrittenSinceLastDelay += toWrite
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/FaultHidingSink.kt
} try { super.write(source, byteCount) } catch (e: IOException) { hasErrors = true onException(e) } } override fun flush() { if (hasErrors) { return } try { super.flush() } catch (e: IOException) { hasErrors = true onException(e) } } override fun close() { try { super.close()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
check(state == STATE_CLOSED) { "too early; can't read the trailers yet" } return trailers ?: EMPTY_HEADERS } override fun flushRequest() { sink.flush() } override fun finishRequest() { sink.flush() } /** Returns bytes of a request header for sending on an HTTP transport. */ fun writeRequest( headers: Headers, requestLine: String, ) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 16.2K bytes - Viewed (0) -
docs/hotfixes.md
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Feb 14 21:36:02 GMT 2024 - 5K bytes - Viewed (0)