Skip to content

Commit b4595fc

Browse files
committed
wip
Signed-off-by: Attila Mészáros <a_meszaros@apple.com>
1 parent 08647db commit b4595fc

File tree

1 file changed

+20
-2
lines changed

1 file changed

+20
-2
lines changed

operator-framework-core/src/test/java/io/javaoperatorsdk/operator/processing/event/source/informer/InformerEventSourceTest.java

Lines changed: 20 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -285,7 +285,7 @@ void multipleCachingFilteringUpdates() {
285285
}
286286

287287
@Test
288-
void multipleCachingFilteringUpdates_variation2() {
288+
void multipleCachingFilteringUpdates_variant2() {
289289
withRealTemporaryResourceCache();
290290

291291
CountDownLatch latch = sendForEventFilteringUpdate(2);
@@ -303,7 +303,7 @@ void multipleCachingFilteringUpdates_variation2() {
303303
}
304304

305305
@Test
306-
void multipleCachingFilteringUpdates_variation3() {
306+
void multipleCachingFilteringUpdates_variant3() {
307307
withRealTemporaryResourceCache();
308308

309309
CountDownLatch latch = sendForEventFilteringUpdate(2);
@@ -320,6 +320,24 @@ void multipleCachingFilteringUpdates_variation3() {
320320
assertNoEventProduced();
321321
}
322322

323+
@Test
324+
void multipleCachingFilteringUpdates_variant4() {
325+
withRealTemporaryResourceCache();
326+
327+
CountDownLatch latch = sendForEventFilteringUpdate(2);
328+
CountDownLatch latch2 =
329+
sendForEventFilteringUpdate(withResourceVersion(testDeployment(), 2), 3);
330+
331+
informerEventSource.onUpdate(
332+
deploymentWithResourceVersion(1), deploymentWithResourceVersion(2));
333+
informerEventSource.onUpdate(
334+
deploymentWithResourceVersion(2), deploymentWithResourceVersion(3));
335+
latch.countDown();
336+
latch2.countDown();
337+
338+
assertNoEventProduced();
339+
}
340+
323341
private void assertNoEventProduced() {
324342
await()
325343
.pollDelay(Duration.ofMillis(50))

0 commit comments

Comments
 (0)