From a990de90fe41456a23e58bd087d2f107d321f3a1 Mon Sep 17 00:00:00 2001
From: Valentin Popov <valentin@popov.link>
Date: Fri, 19 Jul 2024 16:37:58 +0400
Subject: Deleted vendor folder

---
 vendor/flume/examples/async.rs  | 21 ---------------------
 vendor/flume/examples/perf.rs   | 30 ------------------------------
 vendor/flume/examples/select.rs | 25 -------------------------
 vendor/flume/examples/simple.rs | 18 ------------------
 4 files changed, 94 deletions(-)
 delete mode 100644 vendor/flume/examples/async.rs
 delete mode 100644 vendor/flume/examples/perf.rs
 delete mode 100644 vendor/flume/examples/select.rs
 delete mode 100644 vendor/flume/examples/simple.rs

(limited to 'vendor/flume/examples')

diff --git a/vendor/flume/examples/async.rs b/vendor/flume/examples/async.rs
deleted file mode 100644
index a562700..0000000
--- a/vendor/flume/examples/async.rs
+++ /dev/null
@@ -1,21 +0,0 @@
-#[cfg(feature = "async")]
-#[async_std::main]
-async fn main() {
-    let (tx, rx) = flume::bounded(1);
-
-    let t = async_std::task::spawn(async move {
-        while let Ok(msg) = rx.recv_async().await {
-            println!("Received: {}", msg);
-        }
-    });
-
-    tx.send_async("Hello, world!").await.unwrap();
-    tx.send_async("How are you today?").await.unwrap();
-
-    drop(tx);
-
-    t.await;
-}
-
-#[cfg(not(feature = "async"))]
-fn main() {}
diff --git a/vendor/flume/examples/perf.rs b/vendor/flume/examples/perf.rs
deleted file mode 100644
index 054dcbd..0000000
--- a/vendor/flume/examples/perf.rs
+++ /dev/null
@@ -1,30 +0,0 @@
-fn main() {
-    let thread_num = 32;
-    let msg_num = 16;
-
-    let (mut main_tx, main_rx) = flume::bounded::<()>(1);
-
-    for _ in 0..thread_num {
-        let (mut tx, rx) = flume::bounded(1);
-        std::mem::swap(&mut tx, &mut main_tx);
-
-        std::thread::spawn(move || {
-            for msg in rx.iter() {
-                tx.send(msg).unwrap();
-            }
-        });
-    }
-
-    for _ in 0..1000 {
-        let main_tx = main_tx.clone();
-        std::thread::spawn(move || {
-            for _ in 0..msg_num {
-                main_tx.send(Default::default()).unwrap();
-            }
-        });
-
-        for _ in 0..msg_num {
-            main_rx.recv().unwrap();
-        }
-    }
-}
diff --git a/vendor/flume/examples/select.rs b/vendor/flume/examples/select.rs
deleted file mode 100644
index bbe957b..0000000
--- a/vendor/flume/examples/select.rs
+++ /dev/null
@@ -1,25 +0,0 @@
-#[cfg(feature = "select")]
-use flume::Selector;
-
-#[cfg(feature = "select")]
-fn main() {
-    // Create two channels
-    let (red_tx, red_rx) = flume::unbounded();
-    let (blue_tx, blue_rx) = flume::unbounded();
-
-    // Spawn two threads that each send a message into their respective channel
-    std::thread::spawn(move || { let _ = red_tx.send("Red"); });
-    std::thread::spawn(move || { let _ = blue_tx.send("Blue"); });
-
-    // Race them to see which one sends their message first
-    let winner = Selector::new()
-        .recv(&red_rx, |msg| msg)
-        .recv(&blue_rx, |msg| msg)
-        .wait()
-        .unwrap();
-
-    println!("{} won!", winner);
-}
-
-#[cfg(not(feature = "select"))]
-fn main() {}
diff --git a/vendor/flume/examples/simple.rs b/vendor/flume/examples/simple.rs
deleted file mode 100644
index 39cb1bd..0000000
--- a/vendor/flume/examples/simple.rs
+++ /dev/null
@@ -1,18 +0,0 @@
-use std::thread;
-
-fn main() {
-    let (tx, rx) = flume::unbounded();
-
-    let t = thread::spawn(move || {
-        for msg in rx.iter() {
-            println!("Received: {}", msg);
-        }
-    });
-
-    tx.send("Hello, world!").unwrap();
-    tx.send("How are you today?").unwrap();
-
-    drop(tx);
-
-    t.join().unwrap();
-}
-- 
cgit v1.2.3