- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 159 for butter (0.16 sec)
-
okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/HttpLoggingInterceptor.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 09:14:38 GMT 2024 - 11.2K bytes - Viewed (1) -
okhttp-tls/src/test/java/okhttp3/tls/internal/der/DerTest.kt
derWriter.writeUtf8("a".repeat(201)) } assertThat(buffer.readByteString(3)).isEqualTo("1e81c9".decodeHex()) assertThat(buffer.readUtf8()).isEqualTo("a".repeat(201)) } @Test fun `decode primitive bit string`() { val buffer = Buffer() .write("0307040A3B5F291CD0".decodeHex()) val derReader = DerReader(buffer) derReader.read("test") { header ->
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 31.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RequestBodyTest.kt
assertOnFileDescriptor(content = "Hello") { fd -> val requestBody = fd.toRequestBody() val buffer = Buffer() requestBody.writeTo(buffer) assertThat(buffer.readUtf8()).isEqualTo("Hello") assertThrows(IOException::class.java) { requestBody.writeTo(Buffer()) } } } @Test fun testFileDescriptorAfterClose() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.6K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
) synchronized(this@Relay) { // Append new upstream bytes into the buffer. Trim it to its max size. buffer.write(upstreamBuffer, upstreamBytesRead) if (buffer.size > bufferMaxSize) { buffer.skip(buffer.size - bufferMaxSize) } // Now that the file and buffer have bytes, adjust upstreamPos. ******@****.***amPos += upstreamBytesRead }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ResponseBodyJvmTest.kt
import okhttp3.MediaType.Companion.toMediaType import okhttp3.ResponseBody.Companion.toResponseBody import okhttp3.internal.and import okio.Buffer import okio.BufferedSource import okio.ByteString import okio.ByteString.Companion.decodeHex import okio.ForwardingSource import okio.buffer import org.junit.jupiter.api.Test class ResponseBodyJvmTest { @Test fun stringEmpty() { val body = body("")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 13K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerAdapter.kt
*/ fun toDer( writer: DerWriter, value: T, ) fun toDer(value: T): ByteString { val buffer = Buffer() val writer = DerWriter(buffer) toDer(writer, value) return buffer.readByteString() } /** * Returns an adapter that expects this value wrapped by another value. Typically this occurs
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.2K bytes - Viewed (0) -
okhttp-sse/src/test/java/okhttp3/sse/internal/ServerSentEventIteratorTest.kt
override fun onRetryChange(timeMs: Long) { callbacks.add(timeMs) } } val buffer = Buffer().writeUtf8(source) val reader = ServerSentEventReader(buffer, callback) while (reader.processNextEvent()) { } assertThat(buffer.size, "Unconsumed buffer: ${buffer.readUtf8()}") .isEqualTo(0) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/URLConnectionTest.kt
@Test fun contentDisagreesWithChunkedHeaderBodyTooLong() { val builder = MockResponse.Builder() .chunkedBody("abc", 3) val buffer = Buffer() builder.body!!.writeTo(buffer) buffer.writeUtf8("\r\nYOU SHOULD NOT SEE THIS") builder.body(buffer) builder.clearHeaders() builder.addHeader("Transfer-encoding: chunked") server.enqueue(builder.build())
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 131.7K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/internal/duplex/RealStream.kt
import okhttp3.internal.http2.Http2Stream import okio.buffer /** Adapt OkHttp's internal [Http2Stream] type to the public [Stream] type. */ internal class RealStream( private val http2Stream: Http2Stream, ) : Stream { override val requestBody = http2Stream.getSource().buffer() override val responseBody = http2Stream.getSink().buffer() override fun cancel() { http2Stream.closeLater(ErrorCode.CANCEL)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Dec 31 18:24:52 GMT 2022 - 1.1K bytes - Viewed (0) -
okhttp-brotli/src/main/kotlin/okhttp3/brotli/internal/DecompressionBombChecker.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3.brotli.internal import okio.Buffer import okio.ForwardingSource import okio.IOException import okio.Source /** Fails decompression if the ratio is too high. */ internal class DecompressionBombChecker( private val maxRatio: Long, ) {
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)