Fix process to futures03 async_msg
@@ -33,10 +33,9 @@ impl Process {
input: MessageQueue<TransactionMsg>,
) -> Result<(), ()> {
let mut pool = self.pool;
- let mut input = input.compat();
while let Some(input_result) = input.next().await {
- match input_result? {
+ match input_result {
TransactionMsg::SendTransaction(origin, txs) => {
// Note that we cannot use apply_block here, since we don't have a valid context to which to apply
// those blocks. one valid tx in a given context, could be invalid in another. for example
