- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 198 for event2 (0.04 sec)
-
src/test/java/org/codelibs/fess/util/ErrorToWarnRewritePolicyTest.java
.build(); LogEvent event3 = Log4jLogEvent.newBuilder() .setLoggerName("third.logger") .setLevel(Level.ERROR) .setMessage(new SimpleMessage("test message 3")) .build(); LogEvent result1 = policy.rewrite(event1); LogEvent result2 = policy.rewrite(event2); LogEvent result3 = policy.rewrite(event3);
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 11.9K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/entity/SearchLogEventTest.java
// Create different implementations SearchLogEvent event1 = new TestSearchLogEvent("id1", 1L, "type1"); SearchLogEvent event2 = new NullSearchLogEvent(); SearchLogEvent event3 = new EmptySearchLogEvent(); // Test polymorphic behavior SearchLogEvent[] events = { event1, event2, event3 }; for (SearchLogEvent event : events) { // All methods should be callable without exceptions
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 11.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/eventbus/EventBusTest.java
} public void testDeadEventPosting() { GhostCatcher catcher = new GhostCatcher(); bus.register(catcher); bus.post(new DeadEvent(this, EVENT)); List<DeadEvent> events = catcher.getEvents(); assertEquals("The explicit DeadEvent should be delivered.", 1, events.size()); assertEquals("The dead event must not be re-wrapped.", EVENT, events.get(0).getEvent());
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 16 17:42:14 UTC 2025 - 11.3K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/EventBus.java
* * @param event event to post. */ public void post(Object event) { Iterator<Subscriber> eventSubscribers = subscribers.getSubscribers(event); if (eventSubscribers.hasNext()) { dispatcher.dispatch(event, eventSubscribers); } else if (!(event instanceof DeadEvent)) { // the event had no subscribers and was not itself a DeadEvent post(new DeadEvent(this, event)); } } @Override
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 03:10:51 UTC 2024 - 12.7K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt
import java.net.Proxy /** * Listener for metrics events. Extend this class to monitor the quantity, size, and duration of * your application's HTTP calls. * * All start/connect/acquire events will eventually receive a matching end/release event, either * successful (non-null parameters), or failed (non-null throwable). The first common parameters of * each event pair are used to link the event in case of concurrent or repeated events e.g.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue May 27 14:58:02 UTC 2025 - 17.4K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http/CancelTest.kt
cancelLatch.await() val events = listener.eventSequence.filter { isConnectionEvent(it) }.map { it.name } listener.clearAllEvents() assertThat(events).startsWith("CallStart", "ConnectStart", "ConnectEnd", "ConnectionAcquired") if (cancelMode == CANCEL) { assertThat(events).contains("Canceled") } else { assertThat(events).doesNotContain("Canceled") }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 9.8K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
} } func (es *expiryState) enqueueNoncurrentVersions(bucket string, versions []ObjectToDelete, events []lifecycle.Event) { if len(versions) == 0 { return } task := noncurrentVersionsTask{ bucket: bucket, versions: versions, events: events, } wrkr := es.getWorkerCh(task.OpHash()) if wrkr == nil { es.stats.missedExpiryTasks.Add(1) return }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 33.7K bytes - Viewed (0) -
src/main/java/jcifs/audit/SecurityAuditLogger.java
logExecutor.shutdownNow(); Thread.currentThread().interrupt(); } } /** * Log a security event with performance optimizations * * @param type event type * @param severity event severity * @param message event message * @param context additional context */
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 26.6K bytes - Viewed (0) -
cmd/iam-etcd-store.go
// re-init the watch channel. goto outerLoop } for _, event := range watchResp.Events { isCreateEvent := event.IsModify() || event.IsCreate() isDeleteEvent := event.Type == etcd.EventTypeDelete switch { case isCreateEvent: ch <- iamWatchEvent{ isCreated: true, keyPath: string(event.Kv.Key), } case isDeleteEvent: ch <- iamWatchEvent{
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 13.9K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt
fun newClientBuilder(): OkHttpClient.Builder = newClient().newBuilder() @Synchronized private fun addEvent(event: String) { if (recordEvents) { logger?.info(event) synchronized(clientEventsList) { clientEventsList.add(event) } } } @Synchronized private fun initUncaughtException(throwable: Throwable) { if (uncaughtException == null) {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri May 30 21:28:20 UTC 2025 - 10.5K bytes - Viewed (0)