Skip to content

Conversation

@mablr
Copy link
Contributor

@mablr mablr commented Dec 1, 2025

Close #19681

Streams receipts from flashblocks as they arrive, before canonical block finalization.

  • Subscribes to received flashblocks and extracts receipts
  • Returns a Stream of Log items matched with a Filter via matching_block_logs_with_tx_hashes, similarly to ‎EthPubSubInner::log_stream‎
  • Tracks block metadata (number, timestamp) from base flashblock (index 0) for use across the flashblocks sequence
  • This uses fancy scan iterator method to maintain state without requiring a separate handler struct


let all_logs = matching_block_logs_with_tx_hashes(
&filter,
BlockNumHash::new(state.0, fb.diff.block_hash),
Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Not sure if it's relevant to build a BlockNumHash from the flashblock hash (diff.block_hash).

Another matching method could be designed here, but Idk what are the actual filtering needs...

@mablr mablr force-pushed the feature/flashblock_receipts_stream2 branch from bf0b961 to fd34229 Compare December 1, 2025 21:24
@mablr mablr marked this pull request as ready for review December 1, 2025 22:14
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

Status: Backlog

Development

Successfully merging this pull request may close these issues.

Add Flashblocks aware ReceiptStream

1 participant