Home
last modified time | relevance | path

Searched refs:Result (Results 1 – 25 of 117) sorted by relevance

12345

/xiu/protocol/rtmp/src/handshake/
H A Dhandshake_trait.rs4 fn read_c0(&mut self) -> Result<(), HandshakeError>; in read_c0() argument
5 fn read_c1(&mut self) -> Result<(), HandshakeError>; in read_c1() argument
6 fn read_c2(&mut self) -> Result<(), HandshakeError>; in read_c2() argument
8 fn write_s0(&mut self) -> Result<(), HandshakeError>; in write_s0() argument
9 fn write_s1(&mut self) -> Result<(), HandshakeError>; in write_s1() argument
10 fn write_s2(&mut self) -> Result<(), HandshakeError>; in write_s2() argument
14 fn write_c0(&mut self) -> Result<(), HandshakeError>; in write_c0() argument
15 fn write_c1(&mut self) -> Result<(), HandshakeError>; in write_c1() argument
18 fn read_s0(&mut self) -> Result<(), HandshakeError>; in read_s0() argument
19 fn read_s1(&mut self) -> Result<(), HandshakeError>; in read_s1() argument
[all …]
H A Dhandshake_client.rs37 pub async fn flush(&mut self) -> Result<(), HandshakeError> { in flush() argument
42 pub async fn handshake(&mut self) -> Result<(), HandshakeError> { in handshake() argument
77 fn write_c0(&mut self) -> Result<(), HandshakeError> { in write_c0() argument
81 fn write_c1(&mut self) -> Result<(), HandshakeError> { in write_c1() argument
89 fn write_c2(&mut self) -> Result<(), HandshakeError> { in write_c2() argument
94 fn read_s0(&mut self) -> Result<(), HandshakeError> { in read_s0() argument
98 fn read_s1(&mut self) -> Result<(), HandshakeError> { in read_s1() argument
102 fn read_s2(&mut self) -> Result<(), HandshakeError> { in read_s2() argument
H A Dhandshake_server.rs141 fn read_c0(&mut self) -> Result<(), HandshakeError> { in read_c0() argument
146 fn read_c1(&mut self) -> Result<(), HandshakeError> { in read_c1() argument
156 fn read_c2(&mut self) -> Result<(), HandshakeError> { in read_c2() argument
161 fn write_s0(&mut self) -> Result<(), HandshakeError> { in write_s0() argument
166 fn write_s1(&mut self) -> Result<(), HandshakeError> { in write_s1() argument
177 fn write_s2(&mut self) -> Result<(), HandshakeError> { in write_s2() argument
185 fn read_c0(&mut self) -> Result<(), HandshakeError> { in read_c0() argument
190 fn read_c1(&mut self) -> Result<(), HandshakeError> { in read_c1() argument
208 fn read_c2(&mut self) -> Result<(), HandshakeError> { in read_c2() argument
213 fn write_s0(&mut self) -> Result<(), HandshakeError> { in write_s0() argument
[all …]
H A Ddigest.rs27 pub fn read_digest(&mut self) -> Result<(BytesMut, SchemaVersion), DigestError> { in read_digest()
36 pub fn generate_and_fill_digest(&mut self) -> Result<Vec<u8>, DigestError> { in generate_and_fill_digest()
46 pub fn generate_digest(&mut self) -> Result<BytesMut, DigestError> { in generate_digest()
54 fn find_digest_offset(&mut self, version: SchemaVersion) -> Result<usize, DigestError> { in find_digest_offset()
99 ) -> Result<(BytesMut, BytesMut, BytesMut), DigestError> { in cook_raw_message()
110 pub fn make_digest(&mut self, raw_message: Vec<u8>) -> Result<BytesMut, DigestError> { in make_digest()
127 fn generate_and_validate(&mut self, version: SchemaVersion) -> Result<BytesMut, DigestError> { in generate_and_validate()
/xiu/library/bytesio/src/
H A Dbytes_reader.rs55 ) -> Result<Cursor<BytesMut>, BytesReadError> { in read_bytes_cursor()
64 ) -> Result<Cursor<BytesMut>, BytesReadError> { in advance_bytes_cursor()
70 pub fn read_u8(&mut self) -> Result<u8, BytesReadError> { in read_u8()
76 pub fn advance_u8(&mut self) -> Result<u8, BytesReadError> { in advance_u8()
81 pub fn read_u16<T: ByteOrder>(&mut self) -> Result<u16, BytesReadError> { in read_u16()
126 pub fn get(&self, index: usize) -> Result<u8, BytesReadError> { in get()
167 pub async fn read(&mut self) -> Result<(), BytesReadError> { in read() argument
194 ) -> Result<Cursor<BytesMut>, BytesReadError> { in read_bytes_cursor()
202 ) -> Result<Cursor<BytesMut>, BytesReadError> { in advance_bytes_cursor()
207 pub async fn read_u8(&mut self) -> Result<u8, BytesReadError> { in read_u8()
[all …]
H A Dbytes_writer.rs29 pub fn write_u8(&mut self, byte: u8) -> Result<(), BytesWriteError> { in write_u8() argument
34 pub fn or_u8_at(&mut self, position: usize, byte: u8) -> Result<(), BytesWriteError> { in or_u8_at() argument
45 pub fn add_u8_at(&mut self, position: usize, byte: u8) -> Result<(), BytesWriteError> { in add_u8_at() argument
71 pub fn write_u16<T: ByteOrder>(&mut self, bytes: u16) -> Result<(), BytesWriteError> { in write_u16() argument
97 pub fn write(&mut self, buf: &[u8]) -> Result<(), BytesWriteError> { in write() argument
102 pub fn prepend(&mut self, buf: &[u8]) -> Result<(), BytesWriteError> { in prepend() argument
114 pub fn write_random_bytes(&mut self, length: u32) -> Result<(), BytesWriteError> { in write_random_bytes() argument
167 pub fn write_u8(&mut self, byte: u8) -> Result<(), BytesWriteError> { in write_u8() argument
187 pub fn write(&mut self, buf: &[u8]) -> Result<(), BytesWriteError> { in write() argument
191 pub fn write_random_bytes(&mut self, length: u32) -> Result<(), BytesWriteError> { in write_random_bytes() argument
[all …]
H A Dbytesio.rs24 async fn write(&mut self, bytes: Bytes) -> Result<(), BytesIOError>; in write() argument
25 async fn read(&mut self) -> Result<BytesMut, BytesIOError>; in read()
26 async fn read_timeout(&mut self, duration: Duration) -> Result<BytesMut, BytesIOError>; in read_timeout()
68 async fn write(&mut self, bytes: Bytes) -> Result<(), BytesIOError> { in write() argument
73 async fn read_timeout(&mut self, duration: Duration) -> Result<BytesMut, BytesIOError> { in read_timeout()
82 async fn read(&mut self) -> Result<BytesMut, BytesIOError> { in read()
112 async fn write(&mut self, bytes: Bytes) -> Result<(), BytesIOError> { in write() argument
118 async fn read_timeout(&mut self, duration: Duration) -> Result<BytesMut, BytesIOError> { in read_timeout()
127 async fn read(&mut self) -> Result<BytesMut, BytesIOError> { in read()
/xiu/protocol/rtmp/src/protocol_control_messages/
H A Dreader.rs15 pub fn read_set_chunk_size(&mut self) -> Result<u32, ProtocolControlMessageReaderError> { in read_set_chunk_size()
20 pub fn read_abort_message(&mut self) -> Result<u32, ProtocolControlMessageReaderError> { in read_abort_message()
25 pub fn read_acknowledgement(&mut self) -> Result<u32, ProtocolControlMessageReaderError> { in read_acknowledgement()
32 ) -> Result<u32, ProtocolControlMessageReaderError> { in read_window_acknowledgement_size()
39 ) -> Result<SetPeerBandwidthProperties, ProtocolControlMessageReaderError> { in read_set_peer_bandwidth()
H A Dwriter.rs19 ) -> Result<(), ControlMessagesError> { in write_control_message_header() argument
36 ) -> Result<(), ControlMessagesError> { in write_set_chunk_size() argument
48 ) -> Result<(), ControlMessagesError> { in write_abort_message() argument
59 ) -> Result<(), ControlMessagesError> { in write_acknowledgement() argument
70 ) -> Result<(), ControlMessagesError> { in write_window_acknowledgement_size() argument
82 ) -> Result<(), ControlMessagesError> { in write_set_peer_bandwidth() argument
/xiu/protocol/rtmp/src/amf0/
H A Damf0_writer.rs20 pub fn write_anys(&mut self, values: &Vec<Amf0ValueType>) -> Result<(), Amf0WriteError> { in write_anys() argument
27 pub fn write_any(&mut self, value: &Amf0ValueType) -> Result<(), Amf0WriteError> { in write_any() argument
39 pub fn write_number(&mut self, value: &f64) -> Result<(), Amf0WriteError> { in write_number() argument
45 pub fn write_bool(&mut self, value: &bool) -> Result<(), Amf0WriteError> { in write_bool() argument
51 pub fn write_string(&mut self, value: &String) -> Result<(), Amf0WriteError> { in write_string() argument
65 pub fn write_null(&mut self) -> Result<(), Amf0WriteError> { in write_null() argument
70 pub fn write_object_eof(&mut self) -> Result<(), Amf0WriteError> { in write_object_eof() argument
79 ) -> Result<(), Amf0WriteError> { in write_object() argument
95 ) -> Result<(), Amf0WriteError> { in write_eacm_array() argument
H A Damf0_reader.rs17 pub fn read_all(&mut self) -> Result<Vec<Amf0ValueType>, Amf0ReadError> { in read_all()
33 pub fn read_any(&mut self) -> Result<Amf0ValueType, Amf0ReadError> { in read_any()
68 pub fn read_number(&mut self) -> Result<Amf0ValueType, Amf0ReadError> { in read_number()
74 pub fn read_bool(&mut self) -> Result<Amf0ValueType, Amf0ReadError> { in read_bool()
83 pub fn read_raw_string(&mut self) -> Result<String, Amf0ReadError> { in read_raw_string()
92 pub fn read_string(&mut self) -> Result<Amf0ValueType, Amf0ReadError> { in read_string()
97 pub fn read_null(&mut self) -> Result<Amf0ValueType, Amf0ReadError> { in read_null()
101 pub fn is_read_object_eof(&mut self) -> Result<bool, Amf0ReadError> { in is_read_object_eof()
110 pub fn read_object(&mut self) -> Result<Amf0ValueType, Amf0ReadError> { in read_object()
129 pub fn read_ecma_array(&mut self) -> Result<Amf0ValueType, Amf0ReadError> { in read_ecma_array()
[all …]
/xiu/protocol/rtmp/src/user_control_messages/
H A Dwriter.rs17 fn write_control_message_header(&mut self, len: u32) -> Result<(), EventMessagesError> { in write_control_message_header() argument
33 pub async fn write_stream_begin(&mut self, stream_id: u32) -> Result<(), EventMessagesError> { in write_stream_begin() argument
43 pub async fn write_stream_eof(&mut self, stream_id: u32) -> Result<(), EventMessagesError> { in write_stream_eof() argument
54 pub async fn write_stream_dry(&mut self, stream_id: u32) -> Result<(), EventMessagesError> { in write_stream_dry() argument
69 ) -> Result<(), EventMessagesError> { in write_set_buffer_length() argument
84 ) -> Result<(), EventMessagesError> { in write_stream_is_record() argument
95 pub async fn write_ping_request(&mut self, timestamp: u32) -> Result<(), EventMessagesError> { in write_ping_request() argument
106 pub async fn write_ping_response(&mut self, timestamp: u32) -> Result<(), EventMessagesError> { in write_ping_response() argument
H A Dreader.rs19 ) -> Result<message_define::RtmpMessageData, errors::EventMessagesError> { in parse_event()
43 ) -> Result<message_define::RtmpMessageData, errors::EventMessagesError> { in read_set_buffer_length()
55 ) -> Result<message_define::RtmpMessageData, errors::EventMessagesError> { in read_stream_begin()
65 ) -> Result<message_define::RtmpMessageData, errors::EventMessagesError> { in read_stream_is_recorded()
/xiu/protocol/rtsp/src/rtp/rtcp/
H A Drtcp_rr.rs21 impl Unmarshal<&mut BytesReader, Result<Self, RtcpError>> for ReportBlock {
22 fn unmarshal(reader: &mut BytesReader) -> Result<Self, RtcpError> in unmarshal()
38 impl Marshal<Result<BytesMut, RtcpError>> for ReportBlock {
39 fn marshal(&self) -> Result<BytesMut, RtcpError> { in marshal()
61 impl Unmarshal<BytesMut, Result<Self, RtcpError>> for RtcpReceiverReport {
62 fn unmarshal(data: BytesMut) -> Result<Self, RtcpError> in unmarshal()
83 impl Marshal<Result<BytesMut, RtcpError>> for RtcpReceiverReport {
84 fn marshal(&self) -> Result<BytesMut, RtcpError> { in marshal()
H A Drtcp_header.rs23 impl Unmarshal<&mut BytesReader, Result<Self, RtcpError>> for RtcpHeader {
24 fn unmarshal(reader: &mut BytesReader) -> Result<Self, RtcpError> in unmarshal()
41 impl Marshal<Result<BytesMut, RtcpError>> for RtcpHeader {
42 fn marshal(&self) -> Result<BytesMut, RtcpError> { in marshal()
H A Drtcp_app.rs29 impl Unmarshal<BytesMut, Result<Self, RtcpError>> for RtcpApp {
30 fn unmarshal(data: BytesMut) -> Result<Self, RtcpError> in unmarshal()
47 impl Marshal<Result<BytesMut, RtcpError>> for RtcpApp {
48 fn marshal(&self) -> Result<BytesMut, RtcpError> { in marshal()
H A Drtcp_bye.rs29 impl Unmarshal<BytesMut, Result<Self, RtcpError>> for RtcpBye {
30 fn unmarshal(data: BytesMut) -> Result<Self, RtcpError> in unmarshal()
53 impl Marshal<Result<BytesMut, RtcpError>> for RtcpBye {
54 fn marshal(&self) -> Result<BytesMut, RtcpError> { in marshal()
H A Drtcp_sr.rs58 impl Unmarshal<&mut BytesReader, Result<Self, RtcpError>> for RtcpSenderReport {
59 fn unmarshal(reader: &mut BytesReader) -> Result<Self, RtcpError> in unmarshal()
82 impl Marshal<Result<BytesMut, RtcpError>> for RtcpSenderReport {
83 fn marshal(&self) -> Result<BytesMut, RtcpError> { in marshal()
/xiu/library/container/flv/src/
H A Dflv_tag_header.rs83 impl Unmarshal<&mut BytesReader, Result<Self, FlvDemuxerError>> for AudioTagHeader {
84 fn unmarshal(reader: &mut BytesReader) -> Result<Self, FlvDemuxerError> in unmarshal()
104 impl Marshal<Result<BytesMut, FlvMuxerError>> for AudioTagHeader {
105 fn marshal(&self) -> Result<BytesMut, FlvMuxerError> { in marshal()
161 impl Unmarshal<&mut BytesReader, Result<Self, FlvDemuxerError>> for VideoTagHeader {
162 fn unmarshal(reader: &mut BytesReader) -> Result<Self, FlvDemuxerError> in unmarshal()
197 impl Marshal<Result<BytesMut, FlvMuxerError>> for VideoTagHeader {
198 fn marshal(&self) -> Result<BytesMut, FlvMuxerError> { in marshal()
H A Dmuxer.rs32 pub fn write_flv_header(&mut self) -> Result<(), FlvMuxerError> { in write_flv_header() argument
42 ) -> Result<(), FlvMuxerError> { in write_flv_tag_header() argument
58 pub fn write_flv_tag_body(&mut self, body: BytesMut) -> Result<(), FlvMuxerError> { in write_flv_tag_body() argument
63 pub fn write_previous_tag_size(&mut self, size: u32) -> Result<(), FlvMuxerError> { in write_previous_tag_size() argument
/xiu/protocol/rtmp/src/netstream/
H A Dwriter.rs49 ) -> Result<(), NetStreamError> { in write_play() argument
64 ) -> Result<(), NetStreamError> { in write_delete_stream() argument
78 ) -> Result<(), NetStreamError> { in write_close_stream() argument
92 ) -> Result<(), NetStreamError> { in write_release_stream() argument
106 ) -> Result<(), NetStreamError> { in write_fcpublish() argument
120 ) -> Result<(), NetStreamError> { in write_receive_audio() argument
134 ) -> Result<(), NetStreamError> { in write_receive_video() argument
148 ) -> Result<(), NetStreamError> { in write_publish() argument
172 ) -> Result<(), NetStreamError> { in write_pause() argument
187 ) -> Result<(), NetStreamError> { in write_on_bw_done() argument
[all …]
/xiu/library/logger/src/
H A Dtarget.rs2 anyhow::Result,
12 pub fn new(file: File) -> Result<Self> { in new()
20 fn write(&mut self, buf: &[u8]) -> io::Result<usize> { in write()
29 fn flush(&mut self) -> io::Result<()> { in flush() argument
/xiu/protocol/rtmp/src/session/
H A Dclient_session.rs145 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 …]
/xiu/protocol/hls/src/
H A Dserver.rs11 type Result<T> = std::result::Result<T, GenericError>; typedef
14 async fn handle_connection(req: Request<Body>) -> Result<Response<Body>> { in handle_connection()
60 async fn simple_file_send(filename: &str) -> Result<Response<Body>> { in simple_file_send()
72 pub async fn run(port: usize) -> Result<()> { in run() argument
/xiu/protocol/httpflv/src/
H A Ddefine.rs10 pub type HttpResponseDataProducer = UnboundedSender<io::Result<BytesMut>>;
11 pub type HttpResponseDataConsumer = UnboundedReceiver<io::Result<BytesMut>>;

12345