Skip to main content

from_dispatch_stream

Function from_dispatch_stream 

Source
pub fn from_dispatch_stream(
    stream: Pin<Box<dyn Stream<Item = StreamItem> + Send + 'static>>,
    content_type: String,
    provenance: Vec<String>,
) -> PlexusStream
Expand description

Create a PlexusStream from a dispatch stream (convenience function)