- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for Operator (0.3 sec)
-
okhttp/src/test/java/okhttp3/internal/cache2/FileOperatorTest.kt
val buffer = Buffer() operator.read(6, buffer, 21) operator.read(36, buffer, 1) operator.read(5, buffer, 5) operator.read(28, buffer, 8) operator.read(17, buffer, 10) operator.read(36, buffer, 2) operator.read(2, buffer, 4) operator.write(0, buffer, buffer.size) operator.read(0, buffer, 12) operator.read(47, buffer, 3) operator.read(45, buffer, 2)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.8K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/FakeDns.kt
private val requestedHosts: MutableList<String> = mutableListOf() private var nextAddress = 0xff000064L // 255.0.0.100 in IPv4; ::ff00:64 in IPv6. /** Sets the results for `hostname`. */ operator fun set( hostname: String, addresses: List<InetAddress>, ): FakeDns { hostAddresses[hostname] = addresses return this } /** Clears the results for `hostname`. */
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Interceptor.kt
* interceptors. * * ```kotlin * val interceptor = Interceptor { chain: Interceptor.Chain -> * chain.proceed(chain.request()) * } * ``` */ inline operator fun invoke(crossinline block: (chain: Chain) -> Response): Interceptor = Interceptor { block(it) } } interface Chain { fun request(): Request @Throws(IOException::class)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/idn/IdnStringprep.kt
val lcatSet: CodePointSet, ) { /** * Returns [input] in canonical form according to these rules, or null if no such canonical form * exists for it. */ operator fun invoke(input: String): String? = invoke(Buffer().writeUtf8(input)) internal operator fun invoke(input: BufferedSource): String? { // 1. Map. val mapResult = Buffer() while (!input.exhausted()) { val codePoint = input.readUtf8CodePoint()
Plain Text - Registered: Fri Mar 29 11:42:11 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RouteSelector.kt
} /** * Returns true if there's another set of routes to attempt. Every address has at least one route. */ operator fun hasNext(): Boolean = hasNextProxy() || postponedRoutes.isNotEmpty() @Throws(IOException::class) operator fun next(): Selection { if (!hasNext()) throw NoSuchElementException() // Compute the next set of routes to attempt. val routes = mutableListOf<Route>()
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Mar 06 17:33:38 GMT 2024 - 7.2K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/SpecificHostSocketFactory.kt
val defaultAddress: InetSocketAddress?, ) : DelegatingSocketFactory(getDefault()) { private val hostMapping = mutableMapOf<InetAddress, InetSocketAddress>() /** Sets the [real] address for [requested]. */ operator fun set( requested: InetAddress, real: InetSocketAddress, ) { hostMapping[requested] = real } override fun createSocket(): Socket { return object : Socket() {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/WebPlatformUrlTestData.kt
var username = "" var password: String? = null var host = "" var port = "" var path = "" var query = "" var fragment = "" fun expectParseFailure() = scheme.isEmpty() private operator fun set( name: String, value: String, ) { when (name) { "s" -> scheme = value "u" -> username = value "pass" -> password = value "h" -> host = value
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
} } val outputStream = socket.getOutputStream() val inputStream = socket.getInputStream() val reader = Http2Reader(inputStream.source().buffer(), client) val outFramesIterator: Iterator<OutFrame> = outFrames.iterator() val outBytes = bytesOut.readByteArray() var nextOutFrame: OutFrame? = null for (i in 0 until frameCount) { if (nextOutFrame == null && outFramesIterator.hasNext()) {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache2/FileOperator.kt
* this class offers: * * * **Read/write:** read and write using the same operator. * * **Random access:** access any position within the file. * * **Shared channels:** read and write a file channel that's shared between * multiple operators. Note that although the underlying [FileChannel] may be shared, * each [FileOperator] should not be. */ internal class FileOperator(
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Settings.kt
val bit = 1 shl INITIAL_WINDOW_SIZE return if (bit and set != 0) values[INITIAL_WINDOW_SIZE] else DEFAULT_INITIAL_WINDOW_SIZE } fun clear() { set = 0 values.fill(0) } operator fun set( id: Int, value: Int, ): Settings { if (id < 0 || id >= values.size) { return this // Discard unknown settings. } val bit = 1 shl id set = set or bit
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.8K bytes - Viewed (0)