Module stream_source 

Stream source port — consume SSE, WebSocket, or message queue feeds Stream source port trait for event-driven data sources.

Defines the interface for streaming data sources such as WebSocket feeds, Server-Sent Events (SSE), or message queues. Adapters implement this trait to provide event streams that can integrate into the DAG pipeline.

Structs

StreamEvent

A single event received from a streaming source.

Traits

StreamSourcePort

Port trait for streaming data sources.