- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 45 for listener2 (0.59 sec)
-
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
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 84.1K bytes - Viewed (0) -
platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/artifacts/configurations/DefaultConfigurationSpec.groovy
} @Issue("gradle/gradle#1567") def "A copy of a configuration that has no resolution listeners also has no resolution listeners"() { given: def config = conf("conf") expect: config.dependencyResolutionListeners.size() == 1 // the listener that forwards to listener manager when: def copy = config.copy() then:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 23 17:30:13 UTC 2024 - 64.8K bytes - Viewed (0) -
istioctl/pkg/describe/describe.go
Port: uint32(port), } listeners, err := cd.GetListenerConfigDump() if err != nil { return nil, err } for _, l := range listeners.DynamicListeners { if l.ActiveState == nil { continue } // Support v2 or v3 in config dump. See ads.go:RequestedTypes for more info. l.ActiveState.Listener.TypeUrl = v3.ListenerType listenerTyped := &listener.Listener{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 05:23:38 UTC 2024 - 50.4K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/ConfigurationCacheProblemReportingIntegrationTest.groovy
withProblem("Script 'script.gradle': line 10: registration of listener on 'Gradle.buildFinished' is unsupported") withProblem("Script 'script.gradle': line 13: registration of listener on 'Gradle.buildFinished' is unsupported") withProblem("Script 'script.gradle': line 4: registration of listener on 'Gradle.buildFinished' is unsupported")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 56.7K 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(),
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 06 04:21:33 UTC 2024 - 52K bytes - Viewed (0) -
pilot/pkg/model/sidecar_test.go
if numberListeners != configuredListeneres { t.Errorf("Expected %d listeners, Got: %d", configuredListeneres, numberListeners) } if sidecarConfig == nil { services := sidecarScope.EgressListeners[0].services if !reflect.DeepEqual(services, sidecarScope.services) { t.Errorf("services in default egress listener not equals sidecar scope services: %v",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 07 09:38:49 UTC 2024 - 74.3K bytes - Viewed (0) -
pilot/pkg/model/push_context.go
// TCP listeners that conflicted with existing TCP listeners on same port ProxyStatusConflictOutboundListenerTCPOverTCP = monitoring.NewGauge( "pilot_conflict_outbound_listener_tcp_over_current_tcp", "Number of conflicting tcp listeners with current tcp listener.", ) // ProxyStatusConflictInboundListener tracks cases of multiple inbound // listeners - 2 services selecting the same port of the pod.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 09:02:11 UTC 2024 - 91.8K bytes - Viewed (0) -
src/crypto/tls/tls_test.go
} timeout := 100 * time.Microsecond for !t.Failed() { acceptc := make(chan net.Conn) listener := newLocalListener(t) go func() { for { conn, err := listener.Accept() if err != nil { close(acceptc) return } acceptc <- conn } }() addr := listener.Addr().String() dialer := &net.Dialer{ Timeout: timeout, }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 60.5K bytes - Viewed (0) -
pilot/pkg/networking/core/httproute_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 51.4K 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)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 75.4K bytes - Viewed (0)