- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 46 for sank (0.15 sec)
-
okhttp/src/main/kotlin/okhttp3/MultipartReader.kt
private val timeout = Timeout() override fun close() { if (currentPart == this) { currentPart = null } } override fun read( sink: Buffer, byteCount: Long, ): Long { require(byteCount >= 0L) { "byteCount < 0: $byteCount" } check(currentPart == this) { "closed" } source.timeout().intersectWith(timeout) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.1K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
) = error("unsupported") override fun take() = error("unsupported") override fun remainingCapacity() = error("unsupported") override fun drainTo(sink: MutableCollection<in T>) = error("unsupported") override fun drainTo( sink: MutableCollection<in T>, maxElements: Int, ) = error("unsupported") }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 12.6K bytes - Viewed (0) -
okhttp-android/src/main/baseline-prof.txt
HSPLokio/AsyncTimeout$Watchdog;-><init>()V HSPLokio/AsyncTimeout$Watchdog;->run()V HSPLokio/AsyncTimeout$sink$1;-><init>(Lokio/AsyncTimeout;Lokio/Sink;)V HSPLokio/AsyncTimeout$sink$1;->close()V HSPLokio/AsyncTimeout$sink$1;->flush()V HSPLokio/AsyncTimeout$sink$1;->write(Lokio/Buffer;J)V HSPLokio/AsyncTimeout$source$1;-><init>(Lokio/AsyncTimeout;Lokio/Source;)V HSPLokio/AsyncTimeout$source$1;->close()V
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) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
override fun read( sink: Buffer, byteCount: Long, ): Long { while (left == 0) { source.skip(padding.toLong()) padding = 0 if (flags and FLAG_END_HEADERS != 0) return -1L readContinuationHeader() // TODO: test case for empty continuation header? } val read = source.read(sink, minOf(byteCount, left.toLong()))
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/main/kotlin/okhttp3/internal/-UtilCommon.kt
* multiple simultaneous reads.) * * @param file a file in the directory to check. This file shouldn't already exist! */ internal fun FileSystem.isCivilized(file: Path): Boolean { sink(file).use { try { delete(file) return true } catch (_: IOException) { } } delete(file) return false } /** Delete file we expect but don't require to exist. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11K bytes - Viewed (0) -
docs/changelogs/changelog_3x.md
This simple option dramatically changes the behavior of the request body and of the entire call. The `RequestBody.writeTo()` method may now retain a reference to the provided sink and hand it off to another thread to write to it after `writeTo` returns. The `EventListener` may now see requests and responses interleaved in ways not previously
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 14:55:54 GMT 2022 - 50.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/MultipartBody.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.9K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/okio/LoggingFilesystem.kt
override fun delete( path: Path, mustExist: Boolean, ) { log("delete($path)") super.delete(path, mustExist) } override fun sink( path: Path, mustCreate: Boolean, ): Sink { log("sink($path)") return super.sink(path, mustCreate) } override fun source(file: Path): Source { log("source($file)") return super.source(file) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/RequestBody.kt
/** * Returns the number of bytes that will be written to sink in a call to [writeTo], * or -1 if that count is unknown. */ @Throws(IOException::class) open fun contentLength(): Long = commonContentLength() /** Writes the content of this request to [sink]. */ @Throws(IOException::class) abstract fun writeTo(sink: BufferedSink) /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Jan 25 14:41:37 GMT 2024 - 9.6K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/PostStreaming.kt
val requestBody = object : RequestBody() { override fun contentType() = MEDIA_TYPE_MARKDOWN override fun writeTo(sink: BufferedSink) { sink.writeUtf8("Numbers\n") sink.writeUtf8("-------\n") for (i in 2..997) { sink.writeUtf8(String.format(" * $i = ${factor(i)}\n")) } } private fun factor(n: Int): String {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.9K bytes - Viewed (0)