- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 2,683 for EVENT (0.12 sec)
-
okhttp-testing-support/src/main/kotlin/okhttp3/ConnectionEvent.kt
) : ConnectionEvent() { override fun closes(event: ConnectionEvent): Boolean = event is ConnectStart && call == event.call && route == event.route } data class ConnectEnd( override val timestampNs: Long, override val connection: Connection, val route: Route, val call: Call, ) : ConnectionEvent() {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
} /** * Enqueues an event to be run on currently known listeners. * * <p>The {@code toString} method of the Event itself will be used to describe the event in the * case of an error. * * @param event the callback to execute on {@link #dispatch} */ public void enqueue(Event<L> event) { enqueueHelper(event, event); } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Dec 13 19:45:20 UTC 2023 - 8.2K bytes - Viewed (0) -
internal/event/target/redis.go
} // RedisAccessEvent holds event log data and timestamp type RedisAccessEvent struct { Event []event.Event EventTime string } // Validate RedisArgs fields func (r RedisArgs) Validate() error { if !r.Enable { return nil } if r.Format != "" { f := strings.ToLower(r.Format) if f != event.NamespaceFormat && f != event.AccessFormat { return fmt.Errorf("unrecognized format")
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 9.1K bytes - Viewed (0) -
platforms/core-runtime/logging/src/test/groovy/org/gradle/internal/logging/sink/OutputEventRendererTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 01 19:25:32 UTC 2024 - 17.8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/mux_test.go
m := NewBroadcaster(1, DropIfChannelFull) event := Event{Type: Added, Object: &myType{"foo", "hello world"}} // Add a couple watchers watches := make([]Interface, 2) for i := range watches { watches[i], _ = m.Watch() } m.Shutdown() // Send a couple events after closing the broadcast channel. t.Log("Sending event") err := m.Action(event.Type, event.Object)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 16 15:26:25 UTC 2022 - 8K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/lifecycle/internal/DefaultExecutionEventCatapult.java
listener.sessionEnded(event); break; case ProjectSkipped: listener.projectSkipped(event); break; case ProjectStarted: listener.projectStarted(event); break; case ProjectSucceeded: listener.projectSucceeded(event); break;
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Jan 10 12:55:54 UTC 2024 - 4.1K bytes - Viewed (0) -
plugin/pkg/admission/eventratelimit/admission_test.go
} func (r request) withNamespace(namespace string) request { r.namespace = namespace return r } func (r request) withEvent(event *api.Event) request { r.event = event return r } func (r request) withEventComponent(component string) request { return r.withEvent(&api.Event{ Source: api.EventSource{ Component: component, }, }) } func (r request) withDryRun(dryRun bool) request {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 17 13:19:08 UTC 2021 - 15.6K bytes - Viewed (0) -
platforms/ide/tooling-api/src/test/groovy/org/gradle/tooling/internal/consumer/parameters/BuildProgressListenerAdapterForTransformOperationsTest.groovy
assertTrue event.eventTime == 1000 assertTrue event.displayName == "transform started" assertTrue event.descriptor.name == 'some transform' assertTrue event.descriptor.parent == null assertTrue event.descriptor.dependencies.size() == 1 with(event.descriptor.dependencies[0]) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 10.7K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/exec/LogToClient.java
public void onOutput(OutputEvent event) { if (dispatcher != null && (isMatchingBuildLogLevel(event) || isProgressEvent(event))) { dispatcher.submit(event); } } private boolean isProgressEvent(OutputEvent event) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 6.1K bytes - Viewed (0) -
src/internal/trace/testdata/generators/go122-syscall-steal-proc-self.go
b0.Event("GoSyscallBegin", testgen.Seq(1), testgen.NoStack) b0.Event("ProcSteal", trace.ProcID(0), testgen.Seq(2), trace.ThreadID(0)) b0.Event("ProcStart", trace.ProcID(0), testgen.Seq(3)) b0.Event("GoSyscallEndBlocked")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:15:28 UTC 2024 - 1K bytes - Viewed (0)