| /xiu/protocol/rtmp/src/session/ |
| H A D | errors.rs | 21 pub struct SessionError { struct
86 SessionError { in from()
94 SessionError { in from()
110 SessionError { in from()
118 SessionError { in from()
126 SessionError { in from()
134 SessionError { in from()
142 SessionError { in from()
150 SessionError { in from()
158 SessionError { in from()
[all …]
|
| H A D | client_session.rs | 8 errors::{SessionError, SessionErrorValue},
145 pub async fn run(&mut self) -> Result<(), SessionError> { in run() argument
235 ) -> Result<(), SessionError> { in process_messages() argument
287 ) -> Result<(), SessionError> { in on_amf0_command_message() argument
326 return Err(SessionError { in on_amf0_command_message()
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
[all …]
|
| H A D | common.rs | 7 errors::{SessionError, SessionErrorValue},
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
323 return Err(SessionError { in subscribe_from_channels()
339 ) -> Result<(), SessionError> { in unsubscribe_from_channels() argument
363 ) -> Result<(), SessionError> { in publish_to_channels() argument
380 return Err(SessionError { in publish_to_channels()
[all …]
|
| H A D | server_session.rs | 8 errors::{SessionError, SessionErrorValue},
246 ) -> Result<(), SessionError> { in process_messages() argument
288 ) -> Result<(), SessionError> { in on_amf0_command_message() argument
426 ) -> Result<(), SessionError> { in on_connect() argument
454 return Err(SessionError { in on_connect()
495 ) -> Result<(), SessionError> { in on_delete_stream() argument
539 ) -> Result<(), SessionError> { in on_play() argument
668 ) -> Result<(), SessionError> { in on_publish() argument
672 return Err(SessionError { in on_publish()
680 return Err(SessionError { in on_publish()
[all …]
|
| /xiu/protocol/rtsp/src/session/ |
| H A D | errors.rs | 13 pub struct SessionError { struct
45 SessionError { in from()
53 SessionError { in from()
61 SessionError { in from()
69 SessionError { in from()
77 SessionError { in from()
85 SessionError { in from()
93 SessionError { in from()
101 SessionError { in from()
107 impl fmt::Display for SessionError { implementation
[all …]
|
| H A D | mod.rs | 28 use errors::SessionError;
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
242 return Err(SessionError { in handle_describe()
290 return Err(SessionError { in handle_announce()
475 return Err(SessionError { in handle_play()
522 return Err(SessionError { in handle_play()
576 Err(SessionError { in handle_teardown()
[all …]
|
| /xiu/protocol/webrtc/src/session/ |
| H A D | errors.rs | 13 pub struct SessionError { struct
49 impl From<RTCError> for SessionError { implementation
51 SessionError { in from()
59 SessionError { in from()
67 SessionError { in from()
75 SessionError { in from()
83 SessionError { in from()
91 SessionError { in from()
99 SessionError { in from()
105 impl fmt::Display for SessionError { implementation
[all …]
|
| H A D | mod.rs | 32 use errors::SessionError;
78 ) -> Result<(), SessionError> { in run() argument
128 return Err(SessionError { in run()
252 ) -> Result<(), SessionError> { in publish_whip() argument
266 return Err(SessionError { in publish_whip()
303 ) -> Result<(), SessionError> { in unpublish_whip() argument
313 return Err(SessionError { in unpublish_whip()
327 ) -> Result<(), SessionError> { in subscribe_whep() argument
342 return Err(SessionError { in subscribe_whep()
416 ) -> Result<(), SessionError> { in unsubscribe_whep() argument
[all …]
|
| /xiu/protocol/hls/src/ |
| H A D | errors.rs | 4 amf0::errors::Amf0WriteError, cache::errors::MetadataError, session::errors::SessionError,
36 SessionError(#[cause] SessionError), enumerator
49 impl From<SessionError> for MediaError {
50 fn from(error: SessionError) -> Self { in from()
52 value: MediaErrorValue::SessionError(error), in from()
126 SessionError(#[cause] SessionError), enumerator
156 impl From<SessionError> for HlsError {
157 fn from(error: SessionError) -> Self { in from()
159 value: HlsErrorValue::SessionError(error), in from()
|
| H A D | flv_data_receiver.rs | 8 rtmp::session::errors::{SessionError, SessionErrorValue},
126 let session_error = SessionError { in subscribe_from_rtmp_channels()
130 value: HlsErrorValue::SessionError(session_error), in subscribe_from_rtmp_channels()
|
| /xiu/protocol/httpflv/src/ |
| H A D | errors.rs | 7 amf0::errors::Amf0WriteError, cache::errors::MetadataError, session::errors::SessionError,
34 SessionError(SessionError), enumerator
51 impl From<SessionError> for HttpFLvError {
52 fn from(error: SessionError) -> Self { in from()
54 value: HttpFLvErrorValue::SessionError(error), in from()
|
| H A D | httpflv.rs | 9 session::errors::{SessionError, SessionErrorValue},
192 let session_error = SessionError { in subscribe_from_rtmp_channels()
196 value: HttpFLvErrorValue::SessionError(session_error), in subscribe_from_rtmp_channels()
|
| /xiu/protocol/rtmp/src/remuxer/ |
| H A D | errors.rs | 3 amf0::errors::Amf0WriteError, cache::errors::MetadataError, session::errors::SessionError,
24 SessionError(#[cause] SessionError), enumerator
56 impl From<SessionError> for RtmpRemuxerError {
57 fn from(error: SessionError) -> Self { in from()
59 value: RtmpRemuxerErrorValue::SessionError(error), in from()
|