add TODO about shutdown
@@ -93,6 +93,7 @@ impl<T, P: Push<T>> Push<T> for ArcPusher<T, P> {
// }
self.events
.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");
self.pusher.push(element)
