- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 238 for Listener (0.36 sec)
-
istioctl/pkg/authz/testdata/configdump.yaml
} ] } ], "listener_filters": [ { "name": "envoy.filters.listener.tls_inspector", "typed_config": { "@type": "type.googleapis.com/envoy.extensions.filters.listener.tls_inspector.v3.TlsInspector" } }, { "name": "envoy.filters.listener.http_inspector", "typed_config": {
Others - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Jun 21 14:20:23 GMT 2023 - 206.7K bytes - Viewed (2) -
android/guava/src/com/google/common/util/concurrent/AggregateFuture.java
* lets all futures share the same listener. * * We store `localFutures` inside the listener because `this.futures` might be nulled out by * the time the listener runs for the final future -- at which point we need to check all * inputs for exceptions *if* we're collecting values. If we're not, then the listener doesn't * need access to the futures again, so we can just pass `null`.
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 15.4K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/RemovalListener.java
* shared resources. * * @param <K> the most general type of keys this listener can listen for; for example {@code Object} * if any key is acceptable * @param <V> the most general type of values this listener can listen for; for example {@code * Object} if any key is acceptable * @author Charles Fry * @since 10.0 */ @GwtCompatible
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Jun 15 18:00:07 GMT 2021 - 2K bytes - Viewed (0) -
internal/http/server.go
// Handle request using passed handler. handler.ServeHTTP(w, r) }) srv.listenerMutex.Lock() srv.Handler = wrappedHandler srv.listener = listener srv.listenerMutex.Unlock() var l net.Listener = listener if tlsConfig != nil { l = tls.NewListener(listener, tlsConfig) } serve = func() error { return srv.Server.Serve(l) } return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 09 21:25:16 GMT 2024 - 7.7K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/internal/RealEventSource.kt
listener.onFailure(this, IOException("canceled"), response) } else { listener.onClosed(this) } } } private fun ResponseBody.isEventStream(): Boolean { val contentType = contentType() ?: return false return contentType.type == "text" && contentType.subtype == "event-stream" } override fun onFailure( call: Call, e: IOException, ) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/FastFallbackTest.kt
// In the process we made one successful connection attempt. assertThat(listener.recordedEventTypes().filter { it == "ConnectStart" }).hasSize(2) assertThat(listener.recordedEventTypes().filter { it == "ConnectFailed" }).hasSize(1) assertThat(listener.recordedEventTypes().filter { it == "ConnectEnd" }).hasSize(1) } @Test fun reachesIpv6WhenIpv4IsDown() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.3K bytes - Viewed (0) -
docs/features/events.md
![Events Diagram](../assets/images/******@****.***) Here’s a [sample event listener](https://github.com/square/okhttp/blob/master/samples/guide/src/main/java/okhttp3/recipes/PrintEventsNonConcurrent.java) that prints each event with a timestamp. ```java class PrintingEventListener extends EventListener {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 7.7K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/MockFutureListener.java
} /** * Verify that the listener completes in a reasonable amount of time, and Asserts that the future * returns the expected data. * * @throws Throwable if the listener isn't called or if it resulted in a throwable or if the * result doesn't match the expected value. */ public void assertSuccess(Object expectedData) throws Throwable { // Verify that the listener executed in a reasonable amount of time.
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Fri May 12 18:12:42 GMT 2023 - 3K bytes - Viewed (0) -
istioctl/pkg/authz/analyzer_test.go
{ Name: "10.102.11.148_15021", ActiveState: &envoy_admin.ListenersConfigDump_DynamicListenerState{ VersionInfo: "2023-06-20T09:07:41Z/3", Listener: &anypb.Any{ TypeUrl: "type.googleapis.com/envoy.config.listener.v3.Listener", }, LastUpdated: timestamppb.Now(), }, ClientStatus: 453, }, }, }, } tests := []struct { name string
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sun Apr 21 17:42:54 GMT 2024 - 2.8K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/configuration/internal/EnhancedConfigurationConverter.java
final Object bean = instantiateObject(implType); if (null == value) { processConfiguration(lookup, bean, loader, configuration, evaluator, listener); } else { new CompositeBeanHelper(lookup, loader, evaluator, listener).setDefault(bean, value, configuration); } return bean; } catch (final ComponentConfigurationException e) {
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Wed Feb 28 07:40:37 GMT 2024 - 4.6K bytes - Viewed (0)