Struct RtmpHandler

pub struct RtmpHandler<RW: AsyncRead + AsyncWrite + Unpin>(/* private fields */);

The default RTMP handler.

This handles the raw RTMP by well-known communication steps. That is, this performs just following steps.

1. Checks the application name from the Connect command.
2. Checks the playpath from the ReleaseStream/FcPublish command.
3. Provides a message ID when receives the CreateStream command.
4. Checks publication informations from the Publish command.
5. Then receives FLV media data.

If receiving data size exceeds server’s bandwidth, this reports its thing via the Acknowledgement message to its client. And if some error occurs in any step, sends commands which are FcUnpublish and DeleteStream to its client, then terminates its connection. These perform to delete the playpath and a message ID from its context. However also these can be sent from clients.

Examples

use std::marker::PhantomData;
use sheave_core::handlers::{
    RtmpContext,
    VecStream
};
use sheave_server::{
    Server,
    handlers::RtmpHandler,
};

let stream = VecStream::default();
let rtmp_context = RtmpContext::default();
let server = Server::new(stream, rtmp_context, PhantomData::<RtmpHandler<VecStream>>);

Trait Implementations

impl<RW: AsyncRead + AsyncWrite + Unpin> AsyncHandler for RtmpHandler<RW>

fn poll_handle( self: Pin<&mut Self>, cx: &mut FutureContext<'_>, rtmp_context: &mut RtmpContext, ) -> Poll<IOResult<()>>

impl<RW: Debug + AsyncRead + AsyncWrite + Unpin> Debug for RtmpHandler<RW>

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

Formats the value using the given formatter.

impl<RW: AsyncRead + AsyncWrite + Unpin> HandlerConstructor<StreamWrapper<RW>> for RtmpHandler<RW>

fn new(stream: Arc<StreamWrapper<RW>>) -> Self