Don't panic on a sink error (#7666)

paritytech · Dec 3, 2020 · f73ac5e · f73ac5e
1 parent 864ce58
commit f73ac5e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/client/rpc/src/author/mod.rs b/client/rpc/src/author/mod.rs
@@ -215,7 +215,7 @@ impl<P, Client> AuthorApi<TxHash<P>, BlockHash<P>> for Author<P, Client>
 				Ok(watcher) => {
 					subscriptions.add(subscriber, move |sink| {
 						sink
-							.sink_map_err(|_| unimplemented!())
+							.sink_map_err(|e| log::debug!("Subscription sink failed: {:?}", e))
 							.send_all(Compat::new(watcher))
 							.map(|_| ())
 					});