- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,355 for sink (0.16 sec)
-
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/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
Http1ExchangeCodec(client, this, source, sink) } } @Throws(SocketException::class) internal fun newWebSocketStreams(exchange: Exchange): RealWebSocket.Streams { val socket = this.socket!! val source = this.source!! val sink = this.sink!! socket.soTimeout = 0 noNewExchanges() return object : RealWebSocket.Streams(true, source, sink) { override fun close() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 15.4K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/LittleEndianByteArray.java
* * @param sink the output byte array * @param offset the offset into the array at which to start writing * @param value the value to write */ static void store64(byte[] sink, int offset, long value) { // We don't want to assert in production code. assert offset >= 0 && offset + 8 <= sink.length; // Delegates to the fast (unsafe)version or the fallback.
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 9.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Cache.kt
fun writeTo(editor: DiskLruCache.Editor) { editor.newSink(ENTRY_METADATA).buffer().use { sink -> sink.writeUtf8(url.toString()).writeByte('\n'.code) sink.writeUtf8(requestMethod).writeByte('\n'.code) sink.writeDecimalLong(varyHeaders.size.toLong()).writeByte('\n'.code) for (i in 0 until varyHeaders.size) { sink.writeUtf8(varyHeaders.name(i)) .writeUtf8(": ")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 26.8K 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/internal/http2/Http2Writer.kt
require(streamId and 0x80000000.toInt() == 0) { "reserved bit set: $streamId" } sink.writeMedium(length) sink.writeByte(type and 0xff) sink.writeByte(flags and 0xff) sink.writeInt(streamId and 0x7fffffff) } @Throws(IOException::class) override fun close() { this.withLock { closed = true sink.close() } } @Throws(IOException::class)
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/connection/ConnectPlan.kt
val source = this.source!! val sink = this.sink!! val tunnelCodec = Http1ExchangeCodec( // No client for CONNECT tunnels: client = null, carrier = this, source = source, sink = sink, ) source.timeout().timeout(readTimeoutMillis.toLong(), TimeUnit.MILLISECONDS)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 18.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/idn/IdnaMappingTable.kt
sink.writeByte(ranges[rangesIndex + 2].code or 0x80) sink.writeByte(ranges[rangesIndex + 3].code) } 126 -> { // Mapped inline to the sequence: [b2, b3a]. sink.writeByte(ranges[rangesIndex + 2].code) sink.writeByte(ranges[rangesIndex + 3].code or 0x80) } 127 -> { // Mapped inline to the sequence: [b2a, b3a].
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Apr 02 11:39:58 GMT 2024 - 9K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
writeHeaders(sink, response.trailers) } } @Throws(IOException::class) private fun writeHeaders( sink: BufferedSink, headers: Headers, ) { for ((name, value) in headers) { sink.writeUtf8(name) sink.writeUtf8(": ") sink.writeUtf8(value) sink.writeUtf8("\r\n") } sink.writeUtf8("\r\n") sink.flush() }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 37.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
/** * Returns a sink that can be used to write data to the peer. * * @throws IllegalStateException if this stream was initiated by the peer and a [writeHeaders] has * not yet been sent. */ fun getSink(): Sink { this.withLock { check(hasResponseHeaders || isLocallyInitiated) { "reply before requesting the sink" } } return sink }
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)