wip

Author: 0-jake-0

wingfoil/examples/messaging/zmq_pub.rs

@@ -5,19 +5,14 @@ use wingfoil::*;
 
 fn main() {
     env_logger::init();
-
     let port = 5555;
     let period = Duration::from_millis(100);
-    let run_for = RunFor::Duration(Duration::from_secs(10));
-
-    println!("Starting ZMQ sender on port {port}...");
-    println!("Publishing an incrementing counter every {period:?}");
-
     ticker(period)
         .count()
+        //.limit(10)
         .logged("pub", Info)
         .zmq_pub(port)
-        .run(RunMode::RealTime, run_for)
+        .run(RunMode::RealTime, RunFor::Forever)
         .unwrap();
 
     println!("Finished.");

wingfoil/examples/messaging/zmq_sub.rs

@@ -1,25 +1,13 @@
-
+use log::Level::Info;
 use wingfoil::adapters::zmq::zmq_sub;
 use wingfoil::*;
 
 fn main() {
     env_logger::init();
-
     let address = "tcp://127.0.0.1:5555";
-    let run_for = RunFor::Forever;
-
     println!("Starting ZMQ receiver, connecting to {address}...");
-
     zmq_sub::<u64>(address)
-        .logged("received", log::Level::Info)
-        .finally(|values, _| {
-            println!("Received {} messages", values.len());
-            for v in values {
-                println!("  {:?}", v);
-            }
-        })
-        .run(RunMode::RealTime, run_for)
+        .logged("received", Info)
+        .run(RunMode::RealTime, RunFor::Forever)
         .unwrap();
-
-    println!("Receiver finished.");
 }