Fix asynchronous transaction rejections. (#3817)

* Fix handling transaction pool errors.

* Add test.

* Review suggestions.
This commit is contained in:
Tomasz Drwięga
2019-10-15 11:16:10 +02:00
committed by Bastian Köcher
parent ed449bf415
commit 9fe8ee4197
4 changed files with 73 additions and 41 deletions
@@ -69,6 +69,13 @@ impl Subscriptions {
}
}
/// Borrows the internal task executor.
///
/// This can be used to spawn additional tasks on the underyling event loop.
pub fn executor(&self) -> &TaskExecutor {
&self.executor
}
/// Creates new subscription for given subscriber.
///
/// Second parameter is a function that converts Subscriber sink into a future.