- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 563 for eval (0.02 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketReader.kt
* * This class is not thread safe. * * [rfc_6455]: http://tools.ietf.org/html/rfc6455 */ class WebSocketReader( private val isClient: Boolean, val source: BufferedSource, private val frameCallback: FrameCallback, private val perMessageDeflate: Boolean, private val noContextTakeover: Boolean, ) : Closeable { private var closed = false // Stateful data about the current frame. private var opcode = 0
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Jul 29 22:04:11 UTC 2025 - 9.9K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt
private set internal val socket: BufferedSocket = builder.socket val writer = Http2Writer(socket.sink, client) // Visible for testing val readerRunnable = ReaderRunnable(Http2Reader(socket.source, client)) // Guarded by this. private val currentPushRequests = mutableSetOf<Int>() init { if (builder.pingIntervalMillis != 0) {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 31.8K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/ObjectIdentifiers.kt
internal object ObjectIdentifiers { const val EC_PUBLIC_KEY = "1.2.840.10045.2.1" const val SHA256_WITH_ECDSA = "1.2.840.10045.4.3.2" const val RSA_ENCRYPTION = "1.2.840.113549.1.1.1" const val SHA256_WITH_RSA_ENCRYPTION = "1.2.840.113549.1.1.11" const val SUBJECT_ALTERNATIVE_NAME = "2.5.29.17" const val BASIC_CONSTRAINTS = "2.5.29.19" const val COMMON_NAME = "2.5.4.3" const val ORGANIZATIONAL_UNIT_NAME = "2.5.4.11"
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Jan 07 16:05:34 UTC 2024 - 1.1K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt
*/ class RealCall( val client: OkHttpClient, /** The application's original request unadulterated by redirects or auth headers. */ val originalRequest: Request, val forWebSocket: Boolean, ) : Call, Cloneable, Lockable { private val connectionPool: RealConnectionPool = client.connectionPool.delegate internal val eventListener: EventListener = client.eventListenerFactory.create(this)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 11:30:11 UTC 2025 - 17.8K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/CallEvent.kt
override val timestampNs: Long, override val call: Call, val domainName: String, val inetAddressList: List<InetAddress>, ) : CallEvent() { override fun closes(event: CallEvent): Boolean = event is DnsStart && call == event.call && domainName == event.domainName } data class ConnectStart( override val timestampNs: Long, override val call: Call, val inetSocketAddress: InetSocketAddress, val proxy: Proxy?,
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue May 27 14:58:02 UTC 2025 - 7K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/cache/DiskLruCacheTest.kt
@TempDir lateinit var cacheDirFile: File lateinit var cacheDir: Path private val appVersion = 100 private lateinit var journalFile: Path private lateinit var journalBkpFile: Path private val taskFaker = TaskFaker() private val taskRunner = taskFaker.taskRunner private lateinit var cache: DiskLruCache private val toClose = ArrayDeque<DiskLruCache>() private fun createNewCache() {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 75.7K bytes - Viewed (0) -
docs/recipes.md
```kotlin private val executor = Executors.newScheduledThreadPool(1) private val client = OkHttpClient() fun run() { val request = Request.Builder() .url("http://httpbin.org/delay/2") // This URL is served with a 2 second delay. .build() val startNanos = System.nanoTime() val call = client.newCall(request)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 17:01:12 UTC 2025 - 47.8K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/FakeRoutePlanner.kt
import okhttp3.internal.connection.RoutePlanner.ConnectResult class FakeRoutePlanner( val factory: TestValueFactory = TestValueFactory(), val taskFaker: TaskFaker = factory.taskFaker, ) : RoutePlanner, Closeable { val pool = factory.newConnectionPool(routePlanner = this) val events = LinkedBlockingDeque<String>() var canceled = false var autoGeneratePlans = false
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 6.1K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/SessionReuseTest.kt
} val sessionIds = mutableListOf<String>() enableTls() val tlsVersion = TlsVersion.forJavaName(tlsVersion) val spec = ConnectionSpec .Builder(ConnectionSpec.MODERN_TLS) .tlsVersions(tlsVersion) .build() var reuseSession = false val sslContext = handshakeCertificates.sslContext() val systemSslSocketFactory = sslContext.socketFactory
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 6K bytes - Viewed (1) -
samples/tlssurvey/src/main/kotlin/okhttp3/survey/ssllabs/UserAgentCapabilities.kt
val npnProtocols: List<String>, val platform: String?, val requiresSha2: Boolean, val signatureAlgorithms: List<Int>, val suiteIds: List<Int>, val suiteNames: List<String>, val supportsCompression: Boolean, val supportsNpn: Boolean, val supportsRi: Boolean, val supportsSni: Boolean, val supportsStapling: Boolean, val supportsTickets: Boolean, val userAgent: String?, val version: String,
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Apr 02 01:44:15 UTC 2024 - 1.5K bytes - Viewed (0)