stef_buwalda/pism
1
0
Fork 0
mirror of https://github.com/2OOP/pism.git synced 2026-02-04 02:44:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Delete src/test/java/GlobalEventBusTest.java

Browse Source
This commit is contained in:
Bas Antonius de Jong
2025-09-20 18:34:39 +02:00
committed by GitHub
parent a99e08f726
commit 622fba6bae
1 changed files with 0 additions and 131 deletions
Download Patch File Download Diff File Expand all files Collapse all files

131
src/test/java/GlobalEventBusTest.java
View File

@@ -1,131 +0,0 @@
import static org.junit.jupiter.api.Assertions.*;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicReference;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.toop.eventbus.EventMeta;
import org.toop.eventbus.EventRegistry;
import org.toop.eventbus.GlobalEventBus;
public class GlobalEventBusTest {
// Sample event class
public static class TestEvent {
private final String message;
public TestEvent(String message) {
this.message = message;
}
public String getMessage() {
return message;
}
}
@BeforeEach
public void resetRegistry() {
EventRegistry.reset(); // clear ready states and stored events
}
@Test
public void testSubscribeAndPost() {
AtomicBoolean called = new AtomicBoolean(false);
AtomicReference<String> receivedMessage = new AtomicReference<>();
// Subscribe and register listener
EventMeta<TestEvent> meta =
GlobalEventBus.subscribeAndRegister(
TestEvent.class,
e -> {
called.set(true);
receivedMessage.set(e.getMessage());
});
assertTrue(EventRegistry.isReady(TestEvent.class));
assertTrue(meta.isReady());
// Post an event
TestEvent event = new TestEvent("Hello World");
GlobalEventBus.post(event);
// Give Guava EventBus a moment (optional if single-threaded)
try {
Thread.sleep(50);
} catch (InterruptedException ignored) {
}
assertTrue(called.get());
assertEquals("Hello World", receivedMessage.get());
}
@Test
public void testUnregister() {
AtomicBoolean called = new AtomicBoolean(false);
EventMeta<TestEvent> meta =
GlobalEventBus.subscribeAndRegister(TestEvent.class, e -> called.set(true));
assertTrue(meta.isReady());
assertTrue(EventRegistry.isReady(TestEvent.class));
// Unregister listener
GlobalEventBus.unregister(meta);
assertFalse(meta.isReady());
assertFalse(EventRegistry.isReady(TestEvent.class));
// Post event — listener should NOT be called
GlobalEventBus.post(new TestEvent("Test"));
try {
Thread.sleep(50);
} catch (InterruptedException ignored) {
}
assertFalse(called.get());
}
@Test
public void testMultipleListeners() {
AtomicBoolean listener1Called = new AtomicBoolean(false);
AtomicBoolean listener2Called = new AtomicBoolean(false);
EventMeta<TestEvent> l1 =
GlobalEventBus.subscribeAndRegister(
TestEvent.class, e -> listener1Called.set(true));
EventMeta<TestEvent> l2 =
GlobalEventBus.subscribeAndRegister(
TestEvent.class, e -> listener2Called.set(true));
GlobalEventBus.post(new TestEvent("Event"));
try {
Thread.sleep(50);
} catch (InterruptedException ignored) {
}
assertTrue(listener1Called.get());
assertTrue(listener2Called.get());
}
// TODO: Fix registry
// @Test
// public void testEventStoredInRegistry() {
// // Subscribe listener (marks type ready)
// EventMeta<TestEvent> meta = GlobalEventBus.subscribeAndRegister(TestEvent.class, e ->
// {});
//
// // Post the event
// TestEvent event = new TestEvent("StoreTest");
// GlobalEventBus.post(event);
//
// // Retrieve the last stored EventEntry
// EventRegistry.EventEntry<TestEvent> storedEntry =
// EventRegistry.getLastEvent(TestEvent.class);
//
// assertNotNull(storedEntry);
//
// // Compare the inner event
// TestEvent storedEvent = storedEntry.getEvent();
// assertEquals(event, storedEvent);
// }
}