- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for Kistner (0.21 sec)
-
okhttp/src/test/java/okhttp3/EventListenerTest.kt
// Confirm the events occur when expected. listener.takeEvent(CallStart::class.java, 0L) listener.takeEvent(ConnectionAcquired::class.java, applicationInterceptorDelay) listener.takeEvent(RequestHeadersStart::class.java, networkInterceptorDelay) listener.takeEvent(RequestHeadersEnd::class.java, 0L) listener.takeEvent(RequestBodyStart::class.java, 0L) listener.takeEvent(RequestBodyEnd::class.java, requestBodyDelay)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 56.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
return UNSAFE.compareAndSwapObject(future, LISTENERS_OFFSET, expect, update); } /** Performs a GAS operation on the {@link #listeners} field. */ @Override Listener gasListeners(AbstractFuture<?> future, Listener update) { while (true) { Listener listener = future.listeners; if (update == listener) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 22 21:17:24 GMT 2024 - 63K bytes - Viewed (0) -
istioctl/pkg/writer/compare/testdata/configdump_diff.json
], "listener_filters": [ { "name": "envoy.filters.listener.original_dst", "typed_config": { "@type": "type.googleapis.com/envoy.extensions.filters.listener.original_dst.v3.OriginalDst" } }, { "name": "envoy.filters.listener.http_inspector",
Json - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Tue Mar 12 10:02:09 GMT 2024 - 51.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/client/SearchEngineClient.java
client.deletePits(deletePITRequest, listener); } @Override public void getAllPits(final GetAllPitNodesRequest getAllPitNodesRequest, final ActionListener<GetAllPitNodesResponse> listener) { client.getAllPits(getAllPitNodesRequest, listener); } @Override
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 84.1K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/testdata/config_dump.json
{ "@type": "type.googleapis.com/envoy.admin.v3.ListenersConfigDump", "version_info": "2023-12-26T05:57:39Z/1", "static_listeners": [ { "listener": { "@type": "type.googleapis.com/envoy.config.listener.v3.Listener", "address": { "socket_address": { "address": "0.0.0.0", "port_value": 15021 } },
Json - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Wed Jan 03 23:08:06 GMT 2024 - 54.8K bytes - Viewed (1) -
istioctl/pkg/writer/compare/testdata/configdump.json
], "listener_filters": [ { "name": "envoy.filters.listener.original_dst", "typed_config": { "@type": "type.googleapis.com/envoy.extensions.filters.listener.original_dst.v3.OriginalDst" } }, { "name": "envoy.filters.listener.http_inspector",
Json - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Tue Mar 12 10:02:09 GMT 2024 - 52K bytes - Viewed (0) -
guava/src/com/google/common/cache/CacheBuilder.java
return ticker; } return recordsTime ? Ticker.systemTicker() : NULL_TICKER; } /** * Specifies a listener instance that caches should notify each time an entry is removed for any * {@linkplain RemovalCause reason}. Each cache created by this builder will invoke this listener * as part of the routine maintenance described in the class documentation above. *
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Thu Feb 15 16:12:13 GMT 2024 - 51.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
peer: MockHttp2Peer, pushObserver: PushObserver = IGNORE, listener: Http2Connection.Listener = Http2Connection.Listener.REFUSE_INCOMING_STREAMS, ): Http2Connection { val connection = Http2Connection.Builder(true, TaskRunner.INSTANCE) .socket(peer.openSocket()) .pushObserver(pushObserver) .listener(listener) .build() connection.start(sendConnectionPreface = false)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 75.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt
/** Uses [request] to connect a new web socket. */ override fun newWebSocket( request: Request, listener: WebSocketListener, ): WebSocket { val webSocket = RealWebSocket( taskRunner = taskRunner, originalRequest = request, listener = listener, random = Random(), pingIntervalMillis = pingIntervalMillis.toLong(),
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 06 04:21:33 GMT 2024 - 52K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/project/DefaultProjectBuilder.java
.source(modelSource) .locationTracking(true) .listener(listener) .build(); if (pomFile != null) { project.setRootDirectory(rootLocator.findRoot(pomFile.getParent())); }
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Thu Apr 25 14:13:36 GMT 2024 - 55.2K bytes - Viewed (0)