Skip to main content

stream_from_events

Function stream_from_events 

Source
pub fn stream_from_events(
    events: Vec<StreamingEvent>,
) -> Pin<Box<dyn Stream<Item = Result<StreamingEvent, PluginError>> + Send>>
Expand description

Helper to build a plugin stream from a pre-collected vector of events.

Useful for non-streaming plugins or stub implementations that produce all events up-front.