decline to panic
@@ -91,10 +91,11 @@ impl<T, P: Push<T>> Push<T> for ArcPusher<T, P> {
// else {
// self.count += 1;
// }
+ let _ =
self.events
- .send((self.index, Event::Pushed(1)))
+ .send((self.index, Event::Pushed(1)));
// TODO : Perhaps this shouldn't be a fatal error (e.g. in shutdown).
- .expect("Failed to send message count");
+ // .expect("Failed to send message count");
self.pusher.push(element)
}
