add kanal channel

Author: smallnest

channel/Cargo.toml

@@ -15,4 +15,5 @@ flume = "0.10.14"
 futures = "0.3.24"
 futures-channel = "0.3.24"
 futures-util = "0.3.24"
+kanal = "0.1.0-pre1"
 tokio = { version = "1.21.2", features = ["full"] }

channel/src/main.rs

@@ -14,4 +14,6 @@ fn main() {
     async_priority_channel_example();
     futures_channel_mpsc_example();
     futures_channel_oneshot_example();
+    kanal_example();
+    kanal_async_example();
 }

channel/src/others.rs

@@ -223,3 +223,33 @@ pub fn async_priority_channel_example() {
         assert_eq!(r.recv().await, Ok(("Bar", 2)));
     });
 }
+
+pub fn kanal_example() {
+    let (tx, rx) = kanal::unbounded();
+
+    thread::spawn(move || {
+        (0..10).for_each(|i| {
+            tx.send(i).unwrap();
+        });
+
+        drop(tx)
+    });
+
+    let received: u32 = rx.sum();
+    
+    println!("received sum: {}", received);
+}
+
+pub fn kanal_async_example() {
+    let rt = tokio::runtime::Runtime::new().unwrap();
+
+    let (tx, rx) = kanal::unbounded_async();
+
+    rt.block_on(async move {
+        tokio::spawn(async move {
+            tx.send(5).await.unwrap();
+        });
+
+        println!("rx: {}", rx.recv().await.unwrap());
+    });
+}