Struct mmids_core::workflows::steps::ExternalStreamReader

pub struct ExternalStreamReader {
    pub status: StepStatus,
    /* private fields */
}

Represents logic for a basic workflow step that exposes streams to an RTMP endpoint so that an external system can read the video stream. This exposes a read-only interface for media, which means the external system is not expected to push media back into the same workflow as the same identifiable stream. An example of this is providing media for ffmpeg to generate HLS feeds for.

Since this is a read-only interface all media passed into it will flow as-is to the next workflow step.

Fields

status: StepStatus

Implementations

impl ExternalStreamReader

pub fn new(
    watcher_rtmp_app_name: String,
    rtmp_server: UnboundedSender<RtmpEndpointRequest>,
    external_handler_generator: Box<dyn ExternalStreamHandlerGenerator + Sync + Send>
) -> (Self, FutureList)

pub fn handle_resolved_future(
    &mut self,
    notification: Box<dyn StepFutureResult>,
    outputs: &mut StepOutputs
)

pub fn handle_media(
    &mut self,
    media: MediaNotification,
    outputs: &mut StepOutputs
)

pub fn prepare_stream(&mut self, stream_id: StreamId, outputs: &mut StepOutputs)

pub fn stop_all_streams(&mut self)