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.

With publishers

1. Checks the application name from the Connect command.
2. Checks the topic path 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 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 topic path and a message ID from its context. However also these can be sent from clients.

With subscribers

1. Checks the application name from the Connect command.
2. Checks partner’s bandwidsth from the WindowAcknowledgementSize message.
3. Provides a message ID when receives the CreateStream command.
4. Checks the topic path from the FcSubscribe command.
5. Handles one of additional commands either GetStreamLength or SetPlaylist.
6. Checkes subscription informaitons from Play command/
7. The sends FLV media data.

In Both sides, if receiving data size exceeds server’s bandwidth, this reports its thing via the Acknowledgement message to its client.

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