|
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