use try_send insted of send

uuhan · uuhan · commit a78fb964d2ff · 2021-10-14T15:11:43.000+08:00
diff --git a/src/subscriber.rs b/src/subscriber.rs
@@ -296,7 +296,8 @@ impl Subscribers {
 
                     for (_id, (waker, sender)) in subs.iter() {
                         let (tx, rx) = OneShot::pair();
-                        if sender.send(rx).is_err() {
+                        if let Err(err) = sender.try_send(rx) {
+                            error!("send error: {:?}", err);
                             continue;
                         }
                         subscribers.push((waker.clone(), tx));

Original file line number	Diff line number	Diff line change
`@@ -296,7 +296,8 @@ impl Subscribers {`
`296`	`296`
`297`	`297`	`for (_id, (waker, sender)) in subs.iter() {`
`298`	`298`	`let (tx, rx) = OneShot::pair();`
`299`		`- if sender.send(rx).is_err() {`
	`299`	`+ if let Err(err) = sender.try_send(rx) {`
	`300`	`+ error!("send error: {:?}", err);`
`300`	`301`	`continue;`
`301`	`302`	`}`
`302`	`303`	`subscribers.push((waker.clone(), tx));`