- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 32 for cout (0.12 sec)
-
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
} fun acceptFrame() { frameCount++ } /** Maximum length of an outbound data frame. */ fun maxOutboundDataLength(): Int = writer.maxDataLength() /** Count of frames sent or received. */ fun frameCount(): Int = frameCount fun sendFrame(): Http2Writer { outFrames.add(OutFrame(frameCount++, bytesOut.size, false)) return writer } /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.7K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/FakeDns.kt
assertThat(requestedHosts).containsExactly(*expectedHosts) requestedHosts.clear() } /** Allocates and returns `count` fake IPv4 addresses like [255.0.0.100, 255.0.0.101]. */ fun allocate(count: Int): List<InetAddress> { val from = nextAddress nextAddress += count return (from until nextAddress) .map { return@map InetAddress.getByAddress(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.6K bytes - Viewed (0) -
okhttp-hpacktests/src/test/java/okhttp3/internal/http2/HpackRoundTripTest.kt
internal class StoriesTestProvider : SimpleProvider() { override fun arguments(): List<Any> = createStories(RAW_DATA) } private val bytesOut = Buffer() private val hpackWriter = Hpack.Writer(out = bytesOut) @ParameterizedTest @ArgumentsSource(StoriesTestProvider::class) fun testRoundTrip(story: Story) { assumeFalse( story === Story.MISSING, "Test stories missing, checkout git submodule",
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Interceptor.kt
* limitations under the License. */ package okhttp3 import java.io.IOException import java.util.concurrent.TimeUnit /** * Observes, modifies, and potentially short-circuits requests going out and the corresponding * responses coming back in. Typically interceptors add, remove, or transform headers on the request * or response. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.5K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt
* take any event class. * @param elapsedMs the time in milliseconds elapsed since the immediately-preceding event, or * -1L to take any duration. */ fun takeEvent( eventClass: Class<out ConnectionEvent>? = null, elapsedMs: Long = -1L, ): ConnectionEvent { val result = eventSequence.remove() val actualElapsedNs = result.timestampNs - (lastTimestampNs ?: result.timestampNs)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ServerTruncatesRequestTest.kt
), ) call.execute().use { response -> assertThat(response.body.string()).isEqualTo("abc") } val expectedEvents = mutableListOf<String>() // Start out with standard events... expectedEvents += "CallStart" expectedEvents += "ProxySelectStart" expectedEvents += "ProxySelectEnd" expectedEvents += "DnsStart" expectedEvents += "DnsEnd"
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Settings.kt
* Settings are [connection][Http2Connection] scoped. */ class Settings { /** Bitfield of which flags that values. */ private var set: Int = 0 /** Flag values. */ private val values = IntArray(COUNT) /** Returns -1 if unset. */ val headerTableSize: Int get() { val bit = 1 shl HEADER_TABLE_SIZE return if (bit and set != 0) values[HEADER_TABLE_SIZE] else -1 }
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) -
okcurl/src/main/kotlin/okhttp3/curl/internal/-MainCommon.kt
println("$name: $value") } println() } // Stream the response to the System.out as it is returned from the server. val out = System.out.sink() val source = response.body.source() while (!source.exhausted()) { out.write(source.buffer, source.buffer.size) out.flush() } response.body.close() } catch (e: IOException) { e.printStackTrace() } finally {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.7K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/InsecureAndroidTrustManager.kt
override fun getAcceptedIssuers(): Array<X509Certificate> = delegate.acceptedIssuers override fun checkClientTrusted( chain: Array<out X509Certificate>, authType: String?, ) = throw CertificateException("Unsupported operation") override fun checkServerTrusted( chain: Array<out X509Certificate>, authType: String, ) = throw CertificateException("Unsupported operation")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketRecorder.kt
} else { events.add(Failure(t, response)) } } private fun nextEvent(): Any { return events.poll(10, TimeUnit.SECONDS) ?: throw AssertionError("Timed out waiting for event.") } fun assertTextMessage(payload: String?) { assertThat(nextEvent()).isEqualTo(Message(string = payload)) } fun assertBinaryMessage(payload: ByteString?) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.9K bytes - Viewed (0)