- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,333 for copyTo (0.2 sec)
-
mockwebserver/src/main/kotlin/mockwebserver3/internal/BufferMockResponseBody.kt
} internal class BufferMockResponseBody( val buffer: Buffer, ) : MockResponseBody { override val contentLength = buffer.size override fun writeTo(sink: BufferedSink) { buffer.copyTo(sink.buffer) sink.emitCompleteSegments() }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Jan 07 16:05:34 GMT 2024 - 1.1K bytes - Viewed (0) -
okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/internal/IsProbablyUtf8.kt
* signatures. */ fun Buffer.isProbablyUtf8(): Boolean { try { val prefix = Buffer() val byteCount = size.coerceAtMost(64) copyTo(prefix, 0, byteCount) for (i in 0 until 16) { if (prefix.exhausted()) { break } val codePoint = prefix.readUtf8CodePoint()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Jan 07 16:05:34 GMT 2024 - 1.4K bytes - Viewed (0) -
build-logic-commons/basics/src/main/kotlin/gradlebuild/basics/classanalysis/AnalyzeAndShade.kt
} file.isBuildReceipt() -> { Files.copy(file, buildReceipt) } file.isUnseenManifestFilePath() -> { seenManifest = true Files.copy(file, manifest) } } return FileVisitResult.CONTINUE
Plain Text - Registered: Wed May 08 11:36:15 GMT 2024 - Last Modified: Sat Sep 30 16:17:28 GMT 2023 - 6.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
* * In this case the current thread is assigned as the upstream reader. We read bytes from * upstream and copy them to both the file and to the buffer. Finally we release the upstream * reader lock and return the new bytes. * * ## The file * * In this case we copy bytes from the file to the [sink]. * * ## The buffer *
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-dnsoverhttps/src/main/kotlin/okhttp3/dnsoverhttps/DnsRecordCodec.kt
nameBuf.writeByte(utf8ByteCount.toInt()) nameBuf.writeUtf8(label) } nameBuf.writeByte(0) // end nameBuf.copyTo(this, 0, nameBuf.size) writeShort(type) writeShort(1) // CLASS_IN }.readByteString() @Throws(Exception::class) fun decodeAnswers( hostname: String, byteString: ByteString,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/CacheInterceptor.kt
if (!cacheRequestClosed) { cacheRequestClosed = true cacheBody.close() // The cache response is complete! } return -1 } sink.copyTo(cacheBody.buffer, sink.size - bytesRead, bytesRead) cacheBody.emitCompleteSegments() return bytesRead } override fun timeout(): Timeout = source.timeout()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Mar 22 07:09:21 GMT 2024 - 10.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-UtilCommon.kt
comparator: Comparator<String>, ): Int = indexOfFirst { comparator.compare(it, value) == 0 } @Suppress("UNCHECKED_CAST") internal fun Array<String>.concat(value: String): Array<String> { val result = copyOf(size + 1) result[result.lastIndex] = value return result as Array<String> } /** Increments [startIndex] until this string is not ASCII whitespace. Stops at [endIndex]. */
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) -
Dockerfile.hotfix
MINIO_CONFIG_ENV_FILE=config.env \ MC_CONFIG_DIR=/tmp/.mc COPY --from=build /etc/ssl/certs/ca-certificates.crt /etc/ssl/certs/ COPY --from=build /go/bin/minio /usr/bin/minio COPY --from=build /go/bin/mc /usr/bin/mc COPY --from=build /go/bin/cur* /usr/bin/ COPY CREDITS /licenses/CREDITS COPY LICENSE /licenses/LICENSE COPY dockerscripts/docker-entrypoint.sh /usr/bin/docker-entrypoint.sh EXPOSE 9000
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Mar 30 09:41:56 GMT 2024 - 2.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/RealInterceptorChain.kt
return copy(connectTimeoutMillis = checkDuration("connectTimeout", timeout.toLong(), unit)) } override fun readTimeoutMillis(): Int = readTimeoutMillis override fun withReadTimeout( timeout: Int, unit: TimeUnit, ): Interceptor.Chain { check(exchange == null) { "Timeouts can't be adjusted in a network interceptor" }
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) -
NOTICE
The MIT License (MIT) Copyright (c) 2014 Leonardo Menezes Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is
Plain Text - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Wed Jan 15 23:53:08 GMT 2020 - 2.2K bytes - Viewed (0)