refactor: Run all futures concurrently, exit on error

Author: Techassi

rust/operator-binary/src/main.rs

@@ -8,7 +8,7 @@ use crd::{
     APP_NAME, OPERATOR_NAME, ZookeeperCluster, ZookeeperClusterVersion, ZookeeperZnode,
     ZookeeperZnodeVersion, v1alpha1,
 };
-use futures::{StreamExt, pin_mut};
+use futures::StreamExt;
 use stackable_operator::{
     YamlSchema,
     cli::{Command, RunArguments},
@@ -220,10 +220,12 @@ async fn main() -> anyhow::Result<()> {
                     },
                 );
 
-            pin_mut!(zk_controller, znode_controller);
             // kube-runtime's Controller will tokio::spawn each reconciliation, so this only concerns the internal watch machinery
-            let controller_futures = futures::future::select(zk_controller, znode_controller);
-            tokio::join!(controller_futures, eos_checker);
+            tokio::select! {
+                _ = zk_controller => {},
+                _ = znode_controller  => {},
+                _ = eos_checker  => {}
+            }
         }
     }