|
1 | | -// Copyright (c) 2018, 2023, Oracle and/or its affiliates. |
| 1 | +// Copyright (c) 2018, 2025, Oracle and/or its affiliates. |
2 | 2 | // Licensed under the Universal Permissive License v 1.0 as shown at https://oss.oracle.com/licenses/upl. |
3 | 3 |
|
4 | 4 | package oracle.kubernetes.operator; |
|
31 | 31 | import static oracle.kubernetes.operator.tuning.TuningParameters.WATCH_BACKSTOP_RECHECK_COUNT; |
32 | 32 | import static org.hamcrest.MatcherAssert.assertThat; |
33 | 33 | import static org.hamcrest.Matchers.contains; |
34 | | -import static org.hamcrest.Matchers.empty; |
35 | 34 | import static org.hamcrest.Matchers.equalTo; |
36 | 35 | import static org.hamcrest.Matchers.hasEntry; |
37 | 36 |
|
@@ -168,21 +167,6 @@ void receivedEvents_areSentToListeners() { |
168 | 167 | assertThat(callBacks, contains(List.of(addEvent(object1), modifyEvent(object2)))); |
169 | 168 | } |
170 | 169 |
|
171 | | - @Test |
172 | | - @SuppressWarnings("rawtypes") |
173 | | - void receivedEvents_areNotSentToListenersWhenWatchersPaused() { |
174 | | - Object object1 = createObjectWithMetaData(); |
175 | | - Object object2 = createObjectWithMetaData(); |
176 | | - StubWatchFactory.addCallResponses(createAddResponse(object1), createModifyResponse(object2)); |
177 | | - |
178 | | - Watcher watcher = createWatcher(NAMESPACE, stopping, INITIAL_RESOURCE_VERSION); |
179 | | - pauseWatcher(watcher); |
180 | | - assertThat(callBacks, empty()); |
181 | | - |
182 | | - resumeWatcher(watcher); |
183 | | - assertThat(callBacks, contains(List.of(addEvent(object1), modifyEvent(object2)))); |
184 | | - } |
185 | | - |
186 | 170 | @SuppressWarnings("rawtypes") |
187 | 171 | private void resumeWatcher(Watcher watcher1) { |
188 | 172 | watcher1.start(this); |
|
0 commit comments