- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 498 for Sink (0.3 sec)
-
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) -
okhttp/src/test/java/okhttp3/internal/publicsuffix/PublicSuffixListGenerator.kt
} private suspend fun updateLocalFile() = withContext(Dispatchers.IO) { client.newCall(request).executeAsync().use { response -> fileSystem.sink(publicSuffixListDotDat).buffer().use { sink -> sink.writeAll(response.body.source()) } } } private suspend fun readImportResults(): ImportResults = withContext(Dispatchers.IO) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 18 01:24:38 GMT 2024 - 6K bytes - Viewed (0) -
okhttp-brotli/src/main/kotlin/okhttp3/brotli/internal/DecompressionBombChecker.kt
private var outputByteCount = 0L fun wrapInput(source: Source): Source { return object : ForwardingSource(source) { override fun read( sink: Buffer, byteCount: Long, ): Long { val result = super.read(sink, byteCount) if (result == -1L) return result inputByteCount += result return result } } }
Plain Text - Registered: Fri Mar 29 11:42:11 GMT 2024 - Last Modified: Mon Jan 29 22:50:20 GMT 2024 - 1.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/io/FaultyFileSystem.kt
} override fun appendingSink( file: Path, mustExist: Boolean, ): Sink = FaultySink(super.appendingSink(file, mustExist), file) override fun sink( file: Path, mustCreate: Boolean, ): Sink = FaultySink(super.sink(file, mustCreate), file) inner class FaultySink(sink: Sink, private val file: Path) : ForwardingSink(sink) { override fun write( source: Buffer, byteCount: Long, ) {
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-testing-support/src/main/kotlin/okhttp3/UppercaseRequestInterceptor.kt
@Throws(IOException::class) override fun writeTo(sink: BufferedSink) { delegate().writeTo(uppercaseSink(sink).buffer()) } } return request.newBuilder() .method(request.method, uppercaseBody) .build() } private fun uppercaseSink(sink: Sink): Sink { return object : ForwardingSink(sink) { @Throws(IOException::class) override fun write(
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) -
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) -
okhttp/src/test/java/okhttp3/SocksProxy.kt
private fun transfer( fromAddress: InetAddress, toAddress: InetAddress, source: BufferedSource, sink: BufferedSink, ) { executor.execute { val name = "SocksProxy $fromAddress to $toAddress" threadName(name) { val buffer = Buffer() try { sink.use { source.use { while (true) { val byteCount = source.read(buffer, 8192L)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 7.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/FormBody.kt
override fun contentLength(): Long = writeOrCountBytes(null, true) @Throws(IOException::class) override fun writeTo(sink: BufferedSink) { writeOrCountBytes(sink, false) } /** * Either writes this request to [sink] or measures its content length. We have one method * do double-duty to make sure the counting and content are consistent, particularly when it comes
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 09 12:33:05 GMT 2024 - 4.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallKotlinTest.kt
} override fun writeTo(sink: BufferedSink) { sink.writeUtf8("<el") sink.flush() throw IOException("failed to stream the XML") } } class ValidRequestBody : RequestBody() { override fun contentType(): MediaType { return "application/xml".toMediaType() } override fun writeTo(sink: BufferedSink) { sink.writeUtf8("<element/>")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 8.4K bytes - Viewed (0)