pub fn from_dispatch_stream(
stream: Pin<Box<dyn Stream<Item = StreamItem> + Send + 'static>>,
content_type: String,
provenance: Vec<String>,
) -> PlexusStreamExpand description
Create a PlexusStream from a dispatch stream (convenience function)