Skip to content

Commit c6015d3

Browse files
committed
chore(tests): add more tests for DefaultEventSourceManager
1 parent 771cd5f commit c6015d3

File tree

1 file changed

+14
-0
lines changed

1 file changed

+14
-0
lines changed

operator-framework-core/src/test/java/io/javaoperatorsdk/operator/processing/event/DefaultEventSourceManagerTest.java

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -34,6 +34,20 @@ public void registersEventSource() {
3434
assertThat(registeredSources.entrySet()).hasSize(1);
3535
assertThat(registeredSources.get(CUSTOM_EVENT_SOURCE_NAME)).isEqualTo(eventSource);
3636
verify(eventSource, times(1)).setEventHandler(eq(defaultEventHandlerMock));
37+
verify(eventSource, times(1)).start();
38+
}
39+
40+
@Test
41+
public void closeShouldCascadeToEventSources() {
42+
EventSource eventSource = mock(EventSource.class);
43+
EventSource eventSource2 = mock(EventSource.class);
44+
defaultEventSourceManager.registerEventSource(CUSTOM_EVENT_SOURCE_NAME, eventSource);
45+
defaultEventSourceManager.registerEventSource(CUSTOM_EVENT_SOURCE_NAME + "2", eventSource2);
46+
47+
defaultEventSourceManager.close();
48+
49+
verify(eventSource, times(1)).close();
50+
verify(eventSource2, times(1)).close();
3751
}
3852

3953
@Test

0 commit comments

Comments
 (0)