Enum mmids_core::endpoints::rtmp_server::RtmpEndpointPublisherMessage

source · [−]

pub enum RtmpEndpointPublisherMessage {
    PublisherRegistrationFailed,
    PublisherRegistrationSuccessful,
    PublisherRequiringApproval {
        connection_id: ConnectionId,
        stream_key: String,
        response_channel: Sender<ValidationResponse>,
    },
    NewPublisherConnected {
        connection_id: ConnectionId,
        stream_id: StreamId,
        stream_key: String,
        reactor_update_channel: Option<UnboundedReceiver<ReactorWorkflowUpdate>>,
    },
    PublishingStopped {
        connection_id: ConnectionId,
    },
    StreamMetadataChanged {
        publisher: ConnectionId,
        metadata: StreamMetadata,
    },
    NewVideoData {
        publisher: ConnectionId,
        codec: VideoCodec,
        is_keyframe: bool,
        is_sequence_header: bool,
        data: Bytes,
        timestamp: RtmpTimestamp,
        composition_time_offset: i32,
    },
    NewAudioData {
        publisher: ConnectionId,
        codec: AudioCodec,
        is_sequence_header: bool,
        data: Bytes,
        timestamp: RtmpTimestamp,
    },
}

Expand description

Messages the rtmp server endpoint will send to publisher registrants.

Variants

`PublisherRegistrationFailed`

Notification that the publisher registration failed. No further messages will be sent if this is sent.

`PublisherRegistrationSuccessful`

Notification that the publisher registration succeeded.

`PublisherRequiringApproval`

Fields

connection_id: ConnectionId

Unique identifier for the TCP connection that’s requesting to be a publisher

stream_key: String

The stream key that the connection is requesting to be a publisher to

response_channel: Sender<ValidationResponse>

Channel to send the approval or rejection response to

Notification that a new RTMP connection has been made and they have requested to be a publisher on a stream key, but they require validation before being approved.

`NewPublisherConnected`

Fields

connection_id: ConnectionId

Unique identifier for the TCP connection that’s publishing

stream_id: StreamId

Unique identifier for the stream.

stream_key: String

Actual stream key that this stream is coming in from. Mostly used if the registrant specified that Any stream key would be allowed.

reactor_update_channel: Option<UnboundedReceiver<ReactorWorkflowUpdate>>

If provided, this is a channel which will receive workflow updates from a reactor tied to this publisher

Notification that a new RTMP connection has been made and is publishing media

`PublishingStopped`

Fields

connection_id: ConnectionId

Unique identifier for the TCP connection that stopped publishing

Notification that a publisher has stopped publishing. It may still be connected to the server, but it is no longer in a publisher state.

`StreamMetadataChanged`

Fields

publisher: ConnectionId

metadata: StreamMetadata

An RTMP publisher has sent in new stream metadata information

`NewVideoData`

Fields

publisher: ConnectionId

codec: VideoCodec

is_keyframe: bool

is_sequence_header: bool

data: Bytes

timestamp: RtmpTimestamp

composition_time_offset: i32

An RTMP publisher has sent in new video data

`NewAudioData`

Fields

publisher: ConnectionId

codec: AudioCodec

is_sequence_header: bool

data: Bytes

timestamp: RtmpTimestamp

An RTMP publisher has sent in new audio data

Trait Implementations

source

impl Debug for RtmpEndpointPublisherMessage

source

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more

Auto Trait Implementations

impl !RefUnwindSafe for RtmpEndpointPublisherMessage

impl Send for RtmpEndpointPublisherMessage

impl Sync for RtmpEndpointPublisherMessage

impl Unpin for RtmpEndpointPublisherMessage

impl !UnwindSafe for RtmpEndpointPublisherMessage

Blanket Implementations

source

impl<T> Any for T where
T: 'static + ?Sized,

source

pub fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

source

impl<T> Borrow<T> for T where
T: ?Sized,

const: unstable · source

pub fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

source

impl<T> BorrowMut<T> for T where
T: ?Sized,

const: unstable · source

pub fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

source

impl<T> Downcast for T where
T: Any,

source

pub fn into_any(self: Box<T, Global>) -> Box<dyn Any + 'static, Global>

Convert Box<dyn Trait> (where Trait: Downcast) to Box<dyn Any>. Box<dyn Any> can then be further downcast into Box<ConcreteType> where ConcreteType implements Trait. Read more

source

pub fn into_any_rc(self: Rc<T>) -> Rc<dyn Any + 'static>

Convert Rc<Trait> (where Trait: Downcast) to Rc<Any>. Rc<Any> can then be further downcast into Rc<ConcreteType> where ConcreteType implements Trait. Read more

source

pub fn as_any(&self) -> &(dyn Any + 'static)

Convert &Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot generate &Any’s vtable from &Trait’s. Read more

source

pub fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)

Convert &mut Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot generate &mut Any’s vtable from &mut Trait’s. Read more

source

impl<T> DowncastSync for T where
T: Any + Send + Sync,

source

pub fn into_any_arc(self: Arc<T>) -> Arc<dyn Any + Sync + Send + 'static>

Convert Arc<Trait> (where Trait: Downcast) to Arc<Any>. Arc<Any> can then be further downcast into Arc<ConcreteType> where ConcreteType implements Trait. Read more