- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 64 for _observer (0.04 sec)
-
okhttp/src/androidMain/kotlin/okhttp3/internal/platform/android/AndroidSocketAdapter.kt
} } } companion object { val playProviderFactory: DeferredSocketAdapter.Factory = factory("com.google.android.gms.org.conscrypt") /** * Builds a SocketAdapter from an observed implementation class, by grabbing the Class * reference to perform reflection on at runtime. * * @param actualSSLSocketClass the runtime class of Conscrypt class socket. */
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 4.6K bytes - Viewed (0) -
docs/security/tls_configuration_history.md
_2018-07-12_ Added a new extra strict RESTRICTED_TLS configuration inspired by [Google Cloud’s similar policy][googlecloud_ssl_policy]. It is appropriate when both the host platform (JVM/Conscrypt/Android) and target webserver are current. ##### RESTRICTED_TLS cipher suites * TLS_ECDHE_ECDSA_WITH_AES_128_GCM_SHA256 * TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256 * TLS_ECDHE_ECDSA_WITH_AES_256_GCM_SHA384
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Feb 06 16:35:36 UTC 2022 - 9K bytes - Viewed (0) -
docs/de/README.md
Fess enthält auch einen Crawler, der Dokumente auf einem [Webserver](https://fess.codelibs.org/14.17/admin/webconfig-guide.html), [Dateisystem](https://fess.codelibs.org/14.17/admin/fileconfig-guide.html) oder [Datenspeicher](https://fess.codelibs.org/14.17/admin/dataconfig-guide.html) (wie CSV oder Datenbank) durchsuchen...
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Oct 12 07:19:47 UTC 2024 - 7.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java
* * The initial write to delegateRef is made definitely visible via the semantics of * addListener/SES.schedule. The later racy write in cancel() is not guaranteed to be observed, * however that is fine since the correctness is based on the atomic state in our base class. The * initial write to timer is never definitely visible to Fire.run since it is assigned after
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
} }; executor.execute(errorTask); service.execute(barrierTask); // submit directly to the service // the barrier task runs after the error task so we know that the error has been observed by // SequentialExecutor by the time the barrier is satisfied barrier.await(1, SECONDS); executor.execute(barrierTask); // timeout means the second task wasn't even tried
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 11.4K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/ResponseBody.kt
import okio.ByteString import okio.use /** * A one-shot stream from the origin server to the client application with the raw bytes of the * response body. Each response body is supported by an active connection to the webserver. This * imposes both obligations and limits on the client application. * * ### The response body must be closed. * * Each response body is backed by a limited resource like a socket (live network responses) or
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue May 27 14:51:25 UTC 2025 - 11.6K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/tls/ClientAuthTest.kt
server.requireClientAuth() val call = client.newCall(Request.Builder().url(server.url("/")).build()) assertFailsWith<IOException> { call.execute() } // Observed Events are variable // JDK 14 // CallStart, ProxySelectStart, ProxySelectEnd, DnsStart, DnsEnd, ConnectStart, SecureConnectStart,
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 12.7K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt
builder: Builder, ) : Call.Factory, WebSocket.Factory { @get:JvmName("dispatcher") val dispatcher: Dispatcher = builder.dispatcher /** * Returns an immutable list of interceptors that observe the full span of each call: from before * the connection is established (if any) until after the response source is selected (either the * origin server, cache, or both). */ @get:JvmName("interceptors")
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon May 05 16:01:00 UTC 2025 - 51.7K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt
) peer.sendFrame().headers(true, 2, expectedResponseHeaders) peer.sendFrame().data(true, 3, data(0), 0) peer.play() val observer = RecordingPushObserver() // Play it back. val connection = connect(peer, observer, Http2Connection.Listener.REFUSE_INCOMING_STREAMS) val client = connection.newStream(headerEntries("b", "banana"), false)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 75.5K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/HttpUrl.kt
* authentication. * * ### Host * * The host identifies the webserver that serves the URL's resource. It is either a hostname like * `square.com` or `localhost`, an IPv4 address like `192.168.0.1`, or an IPv6 address like `::1`. * * Usually a webserver is reachable with multiple identifiers: its IP addresses, registered
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon May 05 16:01:00 UTC 2025 - 63.5K bytes - Viewed (0)