| /xiu/protocol/rtmp/src/session/ |
| H A D | errors.rs | 21 pub struct SessionError { struct
22 pub value: SessionErrorValue, argument
108 impl From<UnpackError> for SessionError { implementation
116 impl From<MessageError> for SessionError { implementation
156 impl From<BytesIOError> for SessionError { implementation
164 impl From<PackError> for SessionError { implementation
180 impl From<CacheError> for SessionError { implementation
188 impl From<RecvError> for SessionError { implementation
196 impl From<ChannelError> for SessionError { implementation
204 impl fmt::Display for SessionError { implementation
[all …]
|
| H A D | client_session.rs | 145 pub async fn run(&mut self) -> Result<(), SessionError> { in run() argument
210 async fn handshake(&mut self) -> Result<(), SessionError> { in handshake() argument
235 ) -> Result<(), SessionError> { in process_messages() argument
287 ) -> Result<(), SessionError> { in on_amf0_command_message() argument
388 ) -> Result<(), SessionError> { in send_delete_stream() argument
402 ) -> Result<(), SessionError> { in send_publish() argument
418 ) -> Result<(), SessionError> { in send_play() argument
444 ) -> Result<(), SessionError> { in send_window_acknowledgement_size() argument
457 ) -> Result<(), SessionError> { in send_set_buffer_length() argument
516 pub fn on_error(&mut self) -> Result<(), SessionError> { in on_error() argument
[all …]
|
| H A D | server_session.rs | 103 pub async fn run(&mut self) -> Result<(), SessionError> { in run() argument
124 async fn handshake(&mut self) -> Result<(), SessionError> { in handshake() argument
150 async fn read_parse_chunks(&mut self) -> Result<(), SessionError> { in read_parse_chunks() argument
215 async fn play(&mut self) -> Result<(), SessionError> { in play() argument
233 pub async fn send_set_chunk_size(&mut self) -> Result<(), SessionError> { in send_set_chunk_size() argument
246 ) -> Result<(), SessionError> { in process_messages() argument
288 ) -> Result<(), SessionError> { in on_amf0_command_message() argument
426 ) -> Result<(), SessionError> { in on_connect() argument
495 ) -> Result<(), SessionError> { in on_delete_stream() argument
539 ) -> Result<(), SessionError> { in on_play() argument
[all …]
|
| H A D | common.rs | 78 pub async fn send_channel_data(&mut self) -> Result<(), SessionError> { in send_channel_data() argument
110 pub async fn send_audio(&mut self, data: BytesMut, timestamp: u32) -> Result<(), SessionError> { in send_audio() argument
128 pub async fn send_video(&mut self, data: BytesMut, timestamp: u32) -> Result<(), SessionError> { in send_video() argument
150 ) -> Result<(), SessionError> { in send_metadata() argument
172 ) -> Result<(), SessionError> { in on_video_data() argument
199 ) -> Result<(), SessionError> { in on_audio_data() argument
226 ) -> Result<(), SessionError> { in on_meta_data() argument
300 ) -> Result<(), SessionError> { in subscribe_from_channels() argument
339 ) -> Result<(), SessionError> { in unsubscribe_from_channels() argument
363 ) -> Result<(), SessionError> { in publish_to_channels() argument
[all …]
|
| /xiu/protocol/rtsp/src/session/ |
| H A D | errors.rs | 13 pub struct SessionError { struct
14 pub value: SessionErrorValue, argument
43 impl From<BytesIOError> for SessionError { implementation
51 impl From<BytesReadError> for SessionError { implementation
67 impl From<Utf8Error> for SessionError { implementation
75 impl From<PackerError> for SessionError { implementation
83 impl From<UnPackerError> for SessionError { implementation
91 impl From<ChannelError> for SessionError { implementation
99 impl From<RecvError> for SessionError { implementation
107 impl fmt::Display for SessionError { implementation
[all …]
|
| H A D | mod.rs | 86 fn new(reader: &mut BytesReader) -> Result<Option<Self>, SessionError> { in new() argument
128 pub async fn run(&mut self) -> Result<(), SessionError> { in run() argument
157 ) -> Result<(), SessionError> { in on_rtp_over_rtsp_message() argument
177 async fn on_rtsp_message(&mut self) -> Result<(), SessionError> { in on_rtsp_message() argument
217 async fn handle_options(&mut self, rtsp_request: &RtspRequest) -> Result<(), SessionError> { in handle_options() argument
227 async fn handle_describe(&mut self, rtsp_request: &RtspRequest) -> Result<(), SessionError> { in handle_describe() argument
326 async fn handle_setup(&mut self, rtsp_request: &RtspRequest) -> Result<(), SessionError> { in handle_setup() argument
413 async fn handle_play(&mut self, rtsp_request: &RtspRequest) -> Result<(), SessionError> { in handle_play() argument
563 fn handle_teardown(&mut self, rtsp_request: &RtspRequest) -> Result<(), SessionError> { in handle_teardown() argument
590 fn new_tracks(&mut self) -> Result<(), SessionError> { in new_tracks() argument
[all …]
|
| /xiu/protocol/webrtc/src/session/ |
| H A D | errors.rs | 13 pub struct SessionError { struct
14 pub value: SessionErrorValue, argument
49 impl From<RTCError> for SessionError { implementation
57 impl From<BytesIOError> for SessionError { implementation
65 impl From<BytesReadError> for SessionError { implementation
73 impl From<BytesWriteError> for SessionError { implementation
81 impl From<Utf8Error> for SessionError { implementation
89 impl From<ChannelError> for SessionError { implementation
97 impl From<RecvError> for SessionError { implementation
105 impl fmt::Display for SessionError { implementation
[all …]
|
| H A D | mod.rs | 68 pub async fn close_peer_connection(&self) -> Result<(), SessionError> { in close_peer_connection() argument
78 ) -> Result<(), SessionError> { in run() argument
252 ) -> Result<(), SessionError> { in publish_whip() argument
303 ) -> Result<(), SessionError> { in unpublish_whip() argument
327 ) -> Result<(), SessionError> { in subscribe_whep() argument
416 ) -> Result<(), SessionError> { in unsubscribe_whep() argument
502 async fn send_response(&mut self, response: &HttpResponse) -> Result<(), SessionError> { in send_response() argument
|
| /xiu/protocol/hls/src/ |
| H A D | errors.rs | 36 SessionError(#[cause] SessionError), enumerator
126 SessionError(#[cause] SessionError), enumerator
|
| /xiu/protocol/httpflv/src/ |
| H A D | errors.rs | 34 SessionError(SessionError), enumerator
|
| /xiu/protocol/rtmp/src/remuxer/ |
| H A D | errors.rs | 24 SessionError(#[cause] SessionError), enumerator
|