| /xiu/library/streamhub/src/ |
| H A D | errors.rs | 30 pub struct ChannelError { struct
34 impl fmt::Display for ChannelError { implementation
40 impl Fail for ChannelError { implementation
50 impl From<BytesReadError> for ChannelError { implementation
52 ChannelError { in from()
58 impl From<BytesWriteError> for ChannelError { implementation
60 ChannelError { in from()
|
| H A D | lib.rs | 21 errors::{ChannelError, ChannelErrorValue},
521 ) -> Result<(), ChannelError> { in request() argument
536 ) -> Result<(), ChannelError> { in api_statistic() argument
544 return Err(ChannelError { in api_statistic()
552 return Err(ChannelError { in api_statistic()
598 ) -> Result<(), ChannelError> { in subscribe() argument
627 Err(ChannelError { in subscribe()
636 ) -> Result<(), ChannelError> { in unsubscribe() argument
646 return Err(ChannelError { in unsubscribe()
661 ) -> Result<(), ChannelError> { in publish() argument
[all …]
|
| H A D | define.rs | 4 super::errors::ChannelError,
170 pub type SubEventExecuteResultSender = oneshot::Sender<Result<DataReceiver, ChannelError>>;
172 oneshot::Sender<Result<(Option<FrameDataSender>, Option<PacketDataSender>), ChannelError>>;
180 ) -> Result<(), ChannelError>; in send_prior_data() argument
|
| /xiu/protocol/httpflv/src/ |
| H A D | errors.rs | 1 use streamhub::errors::ChannelError;
44 ChannelError(ChannelError), enumerator
91 impl From<ChannelError> for HttpFLvError {
92 fn from(error: ChannelError) -> Self { in from()
94 value: HttpFLvErrorValue::ChannelError(error), in from()
|
| /xiu/protocol/rtsp/src/session/ |
| H A D | errors.rs | 8 streamhub::errors::ChannelError,
36 ChannelError(#[cause] ChannelError), enumerator
91 impl From<ChannelError> for SessionError {
92 fn from(error: ChannelError) -> Self { in from()
94 value: SessionErrorValue::ChannelError(error), in from()
|
| H A D | mod.rs | 54 errors::{ChannelError, ChannelErrorValue},
727 ) -> Result<(), ChannelError> { in send_prior_data() argument
731 return Err(ChannelError { in send_prior_data()
|
| /xiu/protocol/webrtc/src/session/ |
| H A D | errors.rs | 1 use streamhub::errors::ChannelError;
28 ChannelError(#[cause] ChannelError), enumerator
89 impl From<ChannelError> for SessionError {
90 fn from(error: ChannelError) -> Self { in from()
92 value: SessionErrorValue::ChannelError(error), in from()
|
| H A D | mod.rs | 7 errors::ChannelError,
524 ) -> Result<(), ChannelError> { in send_prior_data() argument
|
| /xiu/protocol/rtmp/src/remuxer/ |
| H A D | errors.rs | 8 streamhub::errors::ChannelError,
42 ChannelError(#[cause] ChannelError), enumerator
112 impl From<ChannelError> for RtmpRemuxerError {
113 fn from(error: ChannelError) -> Self { in from()
115 value: RtmpRemuxerErrorValue::ChannelError(error), in from()
|
| /xiu/protocol/rtmp/src/session/ |
| H A D | errors.rs | 16 streamhub::errors::ChannelError,
58 ChannelError(#[cause] ChannelError), enumerator
196 impl From<ChannelError> for SessionError {
197 fn from(error: ChannelError) -> Self { in from()
199 value: SessionErrorValue::ChannelError(error), in from()
|
| H A D | common.rs | 29 errors::{ChannelError, ChannelErrorValue},
488 ) -> Result<(), ChannelError> { in send_prior_data() argument
492 return Err(ChannelError { in send_prior_data()
499 sender.send(meta_body_data).map_err(|_| ChannelError { in send_prior_data()
504 sender.send(audio_seq_data).map_err(|_| ChannelError { in send_prior_data()
509 sender.send(video_seq_data).map_err(|_| ChannelError { in send_prior_data()
521 sender.send(channel_data).map_err(|_| ChannelError { in send_prior_data()
|
| /xiu/protocol/hls/src/ |
| H A D | errors.rs | 7 streamhub::errors::ChannelError,
124 ChannelError(#[cause] ChannelError), enumerator
188 impl From<ChannelError> for HlsError {
189 fn from(error: ChannelError) -> Self { in from()
191 value: HlsErrorValue::ChannelError(error), in from()
|