Skip to content

Commit 5bc1755

Browse files
committed
fix
1 parent eb4b529 commit 5bc1755

File tree

1 file changed

+5
-7
lines changed

1 file changed

+5
-7
lines changed

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/controller/ControllerResourceEventSource.java

Lines changed: 5 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -34,13 +34,13 @@ public class ControllerResourceEventSource<T extends HasMetadata>
3434
private final Controller<T> controller;
3535
private final ResourceEventFilter<T> legacyFilters;
3636

37-
@SuppressWarnings("unchecked")
37+
@SuppressWarnings({"unchecked", "rawtypes"})
3838
public ControllerResourceEventSource(Controller<T> controller) {
3939
super(controller.getCRClient(), controller.getConfiguration());
4040
this.controller = controller;
4141

42-
OnUpdateFilter<? super T> internalOnUpdateFilter =
43-
onUpdateFinalizerNeededAndApplied(controller.useFinalizer(),
42+
OnUpdateFilter internalOnUpdateFilter =
43+
onUpdateFinalizerNeededAndApplied(controller.useFinalizer(),
4444
controller.getConfiguration().getFinalizerName())
4545
.or(onUpdateGenerationAware(controller.getConfiguration().isGenerationAware()))
4646
.or(onUpdateMarkedForDeletion());
@@ -50,10 +50,8 @@ public ControllerResourceEventSource(Controller<T> controller) {
5050
// by default the on add should be processed in all cases regarding internal filters
5151
controller.getConfiguration().onAddFilter().ifPresent(this::setOnAddFilter);
5252
controller.getConfiguration().onUpdateFilter()
53-
.ifPresentOrElse(filter -> {
54-
setOnUpdateFilter(filter.and(internalOnUpdateFilter)),
55-
() -> setOnUpdateFilter(internalOnUpdateFilter);
56-
});
53+
.ifPresentOrElse(filter -> setOnUpdateFilter(filter.and(internalOnUpdateFilter)),
54+
() -> setOnUpdateFilter(internalOnUpdateFilter));
5755
controller.getConfiguration().genericFilter().ifPresent(this::setGenericFilter);
5856
}
5957

0 commit comments

Comments
 (0)