Fix a panic on TokenSource creation

Author: matklad

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "stop-token"
-version = "0.1.0"
+version = "0.1.1"
 authors = ["Aleksey Kladov <[email protected]>"]
 edition = "2018"
 license = "MIT OR Apache-2.0"

src/lib.rs

@@ -101,7 +101,7 @@ pub struct StopToken {
 
 impl Default for StopSource {
     fn default() -> StopSource {
-        let (sender, receiver) = channel::<Never>(0);
+        let (sender, receiver) = channel::<Never>(1);
 
         StopSource {
             _chan: sender,

tests/tests.rs

@@ -0,0 +1,36 @@
+use std::time::Duration;
+
+use async_std::{prelude::*, task, sync::channel};
+
+use stop_token::StopSource;
+
+#[test]
+fn smoke() {
+    task::block_on(async {
+        let (sender, receiver) = channel::<i32>(10);
+        let stop_source = StopSource::new();
+        let task = task::spawn({
+            let stop_token = stop_source.stop_token();
+            let receiver = receiver.clone();
+            async move {
+            let mut xs = Vec::new();
+            let mut stream = stop_token.stop_stream(receiver);
+            while let Some(x) = stream.next().await {
+                xs.push(x)
+            }
+            xs
+        }});
+        sender.send(1).await;
+        sender.send(2).await;
+        sender.send(3).await;
+
+        task::sleep(Duration::from_millis(250)).await;
+        drop(stop_source);
+        task::sleep(Duration::from_millis(250)).await;
+
+        sender.send(4).await;
+        sender.send(5).await;
+        sender.send(6).await;
+        assert_eq!(task.await, vec![1, 2, 3]);
+    })
+}