Module stream_executor 

Stream executor for real-time data processing

This module executes StreamDef blocks by:

1. Connecting to data providers via plugins
2. Managing subscriptions
3. Invoking handlers (on_tick, on_bar, on_connect, on_disconnect, on_error)
4. Maintaining stream state across callbacks

Structs

StreamExecutor

Stream executor manages real-time data streams

StreamState

Stream execution state

Enums

StreamEvent

Message types for stream callbacks