diff --git a/hoptimator-operator/src/main/java/com/linkedin/hoptimator/operator/subscription/SubscriptionReconciler.java b/hoptimator-operator/src/main/java/com/linkedin/hoptimator/operator/subscription/SubscriptionReconciler.java
index 95c43aa..918ca5c 100644
--- a/hoptimator-operator/src/main/java/com/linkedin/hoptimator/operator/subscription/SubscriptionReconciler.java
+++ b/hoptimator-operator/src/main/java/com/linkedin/hoptimator/operator/subscription/SubscriptionReconciler.java
@@ -99,7 +99,7 @@ public Result reconcile(Request request) {
         log.info("Deploying pipeline for {}/{}...", kind, name);
 
         boolean deployed = status.getResources().stream()
-          .map(x -> apply(x, object)).allMatch(x -> x);
+          .allMatch(x -> apply(x, object));
 
         if (deployed) {
           status.setReady(false);
@@ -111,7 +111,7 @@ public Result reconcile(Request request) {
         log.info("Checking status of pipeline for {}/{}...", kind, name);
 
         boolean ready = status.getResources().stream()
-          .map(x -> checkStatus(x)).allMatch(x -> x);
+          .allMatch(x -> checkStatus(x));
 
         if (ready) {
           status.setReady(true);