- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 29 for Kuper (0.16 sec)
-
okhttp/src/test/java/okhttp3/ResponseBodyJvmTest.kt
return object : ForwardingSource(source) { @Throws(IOException::class) override fun close() { closed.set(true) super.close() } }.buffer() } } assertThat(body.string()).isEqualTo("hello") assertThat(closed.get()).isTrue() } @Test fun readerEmpty() {
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-brotli/src/main/kotlin/okhttp3/brotli/internal/DecompressionBombChecker.kt
fun wrapInput(source: Source): Source { return object : ForwardingSource(source) { override fun read( sink: Buffer, byteCount: Long, ): Long { val result = super.read(sink, byteCount) if (result == -1L) return result inputByteCount += result return result } } } fun wrapOutput(source: Source): Source {
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) -
okhttp/src/test/java/okhttp3/URLConnectionTest.kt
body = object : ForwardingRequestBody(transferKind.newRequestBody("def")) { override fun writeTo(sink: BufferedSink) { sinkReference.set(sink) super.writeTo(sink) } }, ), ) assertThat(readAscii(response.body.byteStream(), Int.MAX_VALUE)) .isEqualTo("abc") assertFailsWith<IllegalStateException> {
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) -
okhttp/src/main/kotlin/okhttp3/internal/cache/FaultHidingSink.kt
) { if (hasErrors) { source.skip(byteCount) return } try { super.write(source, byteCount) } catch (e: IOException) { hasErrors = true onException(e) } } override fun flush() { if (hasErrors) { return } try { super.flush() } catch (e: IOException) { hasErrors = true onException(e) } }
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/src/main/kotlin/okhttp3/internal/platform/BouncyCastlePlatform.kt
// Enable ALPN. val names = alpnProtocolNames(protocols) sslParameters.applicationProtocols = names.toTypedArray() sslSocket.parameters = sslParameters } else { super.configureTlsExtensions(sslSocket, hostname, protocols) } } override fun getSelectedProtocol(sslSocket: SSLSocket): String? = if (sslSocket is BCSSLSocket) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
byteCount: Long, ): Long { require(byteCount >= 0L) { "byteCount < 0: $byteCount" } check(!closed) { "closed" } if (bytesRemaining == 0L) return -1 val read = super.read(sink, minOf(bytesRemaining, byteCount)) if (read == -1L) { carrier.noNewExchanges() // The server didn't supply the promised content length. val e = ProtocolException("unexpected end of stream")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 16.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Cache.kt
override fun close() { synchronized(this@Cache) { if (done) return done = true writeSuccessCount++ } super.close() editor.commit() } } } override fun abort() { synchronized(this@Cache) { if (done) return done = true writeAbortCount++
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/CallTest.kt
override fun dispatch(request: RecordedRequest): MockResponse { if (peek().socketPolicy === DisconnectAfterRequest) { requestFinished.await() } return super.dispatch(request) } } dispatcher.enqueueResponse(MockResponse(body = "seed connection pool")) dispatcher.enqueueResponse(MockResponse(socketPolicy = DisconnectAfterRequest))
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 142.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/io/FaultyFileSystem.kt
if (deleteFaults.contains(fileOrDirectory)) throw IOException("boom!") super.deleteRecursively(fileOrDirectory, mustExist) } override fun appendingSink( file: Path, mustExist: Boolean, ): Sink = FaultySink(super.appendingSink(file, mustExist), file) override fun sink( file: Path, mustCreate: Boolean, ): Sink = FaultySink(super.sink(file, mustCreate), file)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/platform/OpenJSSEPlatform.kt
// Enable ALPN. val names = alpnProtocolNames(protocols) sslParameters.applicationProtocols = names.toTypedArray() sslSocket.sslParameters = sslParameters } } else { super.configureTlsExtensions(sslSocket, hostname, protocols) } } override fun getSelectedProtocol(sslSocket: SSLSocket): String? = if (sslSocket is org.openjsse.javax.net.ssl.SSLSocket) {
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 (0)