- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 149 for source (0.15 sec)
-
mockwebserver/src/main/kotlin/mockwebserver3/internal/ThrottledSink.kt
private val delegate: Sink, private val bytesPerPeriod: Long, private val periodDelayNanos: Long, ) : Sink by delegate { private var bytesWrittenSinceLastDelay = 0L override fun write( source: Buffer, byteCount: Long, ) { var bytesLeft = byteCount while (bytesLeft > 0) { if (bytesWrittenSinceLastDelay == bytesPerPeriod) { flush() sleepNanos(periodDelayNanos)
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-testing-support/src/main/kotlin/okhttp3/UppercaseRequestInterceptor.kt
} private fun uppercaseSink(sink: Sink): Sink { return object : ForwardingSink(sink) { @Throws(IOException::class) override fun write( source: Buffer, byteCount: Long, ) { val bytes = source.readByteString(byteCount) delegate.write( Buffer() .write(bytes.toAsciiUppercase()), byteCount, ) } } }
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-testing-support/src/main/kotlin/okhttp3/okio/LoggingFilesystem.kt
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/test/java/okhttp3/InterceptorTest.kt
override fun contentType() = original.contentType() override fun contentLength() = original.contentLength() override fun source() = uppercase(original.source()).buffer() } } private fun uppercase(original: Source): Source { return object : ForwardingSource(original) { override fun read( sink: Buffer, byteCount: Long, ): Long {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Jan 14 10:20:09 GMT 2024 - 27.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketReaderTest.kt
private val serverReader = WebSocketReader( isClient = false, source = data, frameCallback = callback.asFrameCallback(), perMessageDeflate = false, noContextTakeover = false, ) private val serverReaderWithCompression = WebSocketReader( isClient = false, source = data, frameCallback = callback.asFrameCallback(), perMessageDeflate = true,
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/http/DateFormatting.kt
/* * Copyright (C) 2011 The Android Open Source Project * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/SocksProxy.kt
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/test/java/okhttp3/WholeOperationTimeoutTest.kt
val call = client.newCall(request) call.timeout().timeout(250, TimeUnit.MILLISECONDS) val response = call.execute() Thread.sleep(500) assertFailsWith<IOException> { response.body.source().readUtf8() }.also { expected -> assertThat(expected.message).isEqualTo("timeout") assertThat(call.isCanceled()).isTrue() } } @Test fun timeoutReadingResponseWithEnqueue() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/idn/StringprepReader.kt
* ``` * 0221 * 0234-024F * 0000-001F; [CONTROL CHARACTERS] * 007F; DELETE * ``` */ fun readCodePointSet(path: Path): RangeListCodePointSet { fileSystem.source(path).buffer().use { source -> return source.readCodePointSet() } } /** * Reads a set of mapping lines like the following: * * ``` * 180C; ; Map to nothing * 0041; 0061; Case map
Plain Text - Registered: Fri Mar 29 11:42:11 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ResponseJvmTest.kt
* most [BufferedSource] instances, but not of [Buffer]. */ private fun responseBody(content: String): ResponseBody { val data = Buffer().writeUtf8(content) val source: Source = object : Source { var closed = false override fun close() { closed = true } override fun read( sink: Buffer, byteCount: Long,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.1K bytes - Viewed (0)