diff --git a/subxt/src/tx/tx_progress.rs b/subxt/src/tx/tx_progress.rs index deab618efa..3223eb5dd2 100644 --- a/subxt/src/tx/tx_progress.rs +++ b/subxt/src/tx/tx_progress.rs @@ -152,16 +152,19 @@ impl> Stream for TxProgress { mut self: std::pin::Pin<&mut Self>, cx: &mut std::task::Context<'_>, ) -> std::task::Poll> { + eprintln!("-- poll_next"); let sub = match self.sub.as_mut() { Some(sub) => sub, None => return Poll::Ready(None), }; - eprintln!("poll_next"); sub.poll_next_unpin(cx).map_ok(|status| { match status { SubstrateTxStatus::Future => TxStatus::Future, - SubstrateTxStatus::Ready => TxStatus::Ready, + SubstrateTxStatus::Ready => { + eprintln!("-- ready"); + TxStatus::Ready + }, SubstrateTxStatus::Broadcast(peers) => TxStatus::Broadcast(peers), SubstrateTxStatus::InBlock(hash) => { TxStatus::InBlock(TxInBlock::new(