Merge pull request #1 from vitdevelop/main

Add tokio-console for data-channels-flow-control

Author: Rusty Rain

Cargo.toml

@@ -36,6 +36,7 @@ serde_json = "1.0"
 bytes = "1"
 lazy_static = "1.4"
 rand = "0.8"
+console-subscriber = { git = "https://github.com/tokio-rs/console", branch = "main" }
 
 [profile.dev]
 opt-level = 0

examples/data-channels-flow-control/data-channels-flow-control.rs

@@ -93,15 +93,16 @@ async fn create_offerer() -> Result<Arc<RTCPeerConnection>> {
         tokio::spawn(async move {
             let buf = Bytes::from_static(&[0u8; 1024]);
             while dc2.send(&buf).await.is_ok() {
+                tokio::time::sleep(Duration::from_millis(10)).await;
                 let buffered_amount = dc2.buffered_amount().await;
                 if buffered_amount + buf.len() > MAX_BUFFERED_AMOUNT {
                     // Wait until the bufferedAmount becomes lower than the threshold
-                    println!(
-                        "buffered_amount {} + sent {} > MAX_BUFFERED_AMOUNT {}",
-                        buffered_amount,
-                        buf.len(),
-                        MAX_BUFFERED_AMOUNT
-                    );
+                    // println!(
+                    //     "buffered_amount {} + sent {} > MAX_BUFFERED_AMOUNT {}",
+                    //     buffered_amount,
+                    //     buf.len(),
+                    //     MAX_BUFFERED_AMOUNT
+                    // );
                     let _ = send_more_ch_rx.recv().await;
                 }
             }
@@ -206,6 +207,8 @@ async fn create_answerer() -> Result<Arc<RTCPeerConnection>> {
 
 #[tokio::main]
 async fn main() -> Result<()> {
+    console_subscriber::init();
+
     let mut app = App::new("data-channels-flow-control")
         .version("0.1.0")
         .author("Rain Liu <yliu@webrtc.rs>")