From 01cc739989eda5e0970e920644609c174676b6ba Mon Sep 17 00:00:00 2001
From: Tony Garnock-Jones <tonyg@leastfixedpoint.com>
Date: Mon, 11 May 2020 23:57:24 +0200
Subject: [PATCH] Count events as well as turns per second

---
 examples/consumer.rs |  7 ++++++-
 examples/producer.rs | 21 +++++++++++++++++++++
 2 files changed, 27 insertions(+), 1 deletion(-)

diff --git a/examples/consumer.rs b/examples/consumer.rs
index 0eaeecb..08d5448 100644
--- a/examples/consumer.rs
+++ b/examples/consumer.rs
@@ -1,3 +1,5 @@
+#![recursion_limit = "256"]
+
 use syndicate::{V, value::Value};
 use syndicate::packets::{ClientCodec, C2S, S2C, Action};
 use tokio::net::TcpStream;
@@ -26,12 +28,14 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
 
     let mut stats_timer = interval(Duration::from_secs(1));
     let mut turn_counter = 0;
+    let mut event_counter = 0;
 
     loop {
         select! {
             _instant = stats_timer.next().boxed().fuse() => {
-                print!("{:?} turns in the last second\n", turn_counter);
+                print!("{:?} turns, {:?} events in the last second\n", turn_counter, event_counter);
                 turn_counter = 0;
+                event_counter = 0;
             },
             frame = frames.next().boxed().fuse() => match frame {
                 None => return Ok(()),
@@ -40,6 +44,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
                     S2C::Turn(es) => {
                         // print!("{:?}\n", es);
                         turn_counter = turn_counter + 1;
+                        event_counter = event_counter + es.len();
                     },
                     S2C::Ping() => frames.send(C2S::Pong()).await?,
                     S2C::Pong() => (),
diff --git a/examples/producer.rs b/examples/producer.rs
index a4ba8f5..da87830 100644
--- a/examples/producer.rs
+++ b/examples/producer.rs
@@ -12,6 +12,27 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     let mut frames = Framed::new(TcpStream::connect("127.0.0.1:8001").await?,
                                  ClientCodec::standard());
     frames.send(C2S::Connect(Value::from("chat").wrap())).await?;
+
+    // let m = Action::Message(
+    //     Value::simple_record("Says", vec![
+    //         Value::from("producer").wrap(),
+    //         Value::from(123).wrap(),
+    //     ]).wrap());
+    // loop {
+    //     frames.send(C2S::Turn(vec![
+    //         m.clone(),
+    //         m.clone(),
+    //         m.clone(),
+    //         m.clone(),
+    //         m.clone(),
+    //         m.clone(),
+    //         m.clone(),
+    //         m.clone(),
+    //         m.clone(),
+    //         m.clone(),
+    //     ])).await?;
+    // }
+
     let mut counter: u64 = 0;
     loop {
         counter = counter + 1;