pub async fn stream_in_chain_transactions(
    rpc: Arc<dyn BitcoinCoreApi + Send + Sync>,
    from_height: u32,
    num_confirmations: u32
) -> impl Stream<Item = Result<(BlockHash, Transaction), Error>> + Unpin
Expand description

Stream all transactions in blocks produced by Bitcoin Core.

Arguments:

  • rpc - bitcoin rpc
  • from_height - height of the first block of the stream
  • num_confirmations - minimum for a block to be accepted