Struct StreamEngine 

pub struct StreamEngine { /* private fields */ }

The top-level streaming engine.

Usage

use chaincodec_stream::{StreamEngine, StreamConfig};
// ... build engine, call run(), receive from subscriber ...

Implementations

impl StreamEngine

pub fn new( config: StreamConfig, registry: Arc<dyn SchemaRegistry>, ) -> (Self, Receiver<DecodedEvent>)

Create a new StreamEngine.

pub fn add_listener(&mut self, listener: Arc<dyn BlockListener>)

Register a chain listener.

pub fn add_decoder( &mut self, chain_slug: impl Into<String>, decoder: Arc<dyn ChainDecoder>, )

Register a chain decoder.

pub fn subscribe(&self) -> Receiver<DecodedEvent>

Subscribe to the decoded event stream. Call before run() to avoid missing events.

pub fn metrics(&self) -> StreamMetrics

Returns a snapshot of current metrics.

pub async fn run(self: Arc<Self>)

Start the engine. Spawns one Tokio task per chain listener. This method returns immediately; listeners run in the background.