---

croncat-pipeline

This crate exposes the block ingestion pipeline API to other crates.

Major Parts

• provider.rs is for allowing multiple streams to run concurrently and send messages into a tokio::sync::mpsc unbounded channel.

• sequencer.rs takes in a tokio::sync::mpsc unbounded channel and deduplicates/ensures the order of the incoming messages.

• dispatcher.rs takes in a tokio::sync::mpsc unbounded channel and fans the messages out to a all who subscribe to the tokio::sync::broadcast channel.