Home
last modified time | relevance | path

Searched defs:Result (Results 1 – 25 of 88) sorted by relevance

1234

/xiu/protocol/rtmp/src/handshake/
H A Dhandshake_trait.rs4 fn read_c0(&mut self) -> Result<(), HandshakeError>; in read_c0()
5 fn read_c1(&mut self) -> Result<(), HandshakeError>; in read_c1()
6 fn read_c2(&mut self) -> Result<(), HandshakeError>; in read_c2()
8 fn write_s0(&mut self) -> Result<(), HandshakeError>; in write_s0()
9 fn write_s1(&mut self) -> Result<(), HandshakeError>; in write_s1()
10 fn write_s2(&mut self) -> Result<(), HandshakeError>; in write_s2()
14 fn write_c0(&mut self) -> Result<(), HandshakeError>; in write_c0()
15 fn write_c1(&mut self) -> Result<(), HandshakeError>; in write_c1()
18 fn read_s0(&mut self) -> Result<(), HandshakeError>; in read_s0()
19 fn read_s1(&mut self) -> Result<(), HandshakeError>; in read_s1()
[all …]
H A Dhandshake_client.rs37 pub async fn flush(&mut self) -> Result<(), HandshakeError> { in flush()
42 pub async fn handshake(&mut self) -> Result<(), HandshakeError> { in handshake()
77 fn write_c0(&mut self) -> Result<(), HandshakeError> { in write_c0()
81 fn write_c1(&mut self) -> Result<(), HandshakeError> { in write_c1()
89 fn write_c2(&mut self) -> Result<(), HandshakeError> { in write_c2()
94 fn read_s0(&mut self) -> Result<(), HandshakeError> { in read_s0()
98 fn read_s1(&mut self) -> Result<(), HandshakeError> { in read_s1()
102 fn read_s2(&mut self) -> Result<(), HandshakeError> { in read_s2()
H A Dhandshake_server.rs141 fn read_c0(&mut self) -> Result<(), HandshakeError> { in read_c0()
146 fn read_c1(&mut self) -> Result<(), HandshakeError> { in read_c1()
156 fn read_c2(&mut self) -> Result<(), HandshakeError> { in read_c2()
161 fn write_s0(&mut self) -> Result<(), HandshakeError> { in write_s0()
166 fn write_s1(&mut self) -> Result<(), HandshakeError> { in write_s1()
177 fn write_s2(&mut self) -> Result<(), HandshakeError> { in write_s2()
185 fn read_c0(&mut self) -> Result<(), HandshakeError> { in read_c0()
190 fn read_c1(&mut self) -> Result<(), HandshakeError> { in read_c1()
208 fn read_c2(&mut self) -> Result<(), HandshakeError> { in read_c2()
213 fn write_s0(&mut self) -> Result<(), HandshakeError> { in write_s0()
[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()
33 pub async fn write_stream_begin(&mut self, stream_id: u32) -> Result<(), EventMessagesError> { in write_stream_begin()
43 pub async fn write_stream_eof(&mut self, stream_id: u32) -> Result<(), EventMessagesError> { in write_stream_eof()
54 pub async fn write_stream_dry(&mut self, stream_id: u32) -> Result<(), EventMessagesError> { in write_stream_dry()
69 ) -> Result<(), EventMessagesError> { in write_set_buffer_length()
84 ) -> Result<(), EventMessagesError> { in write_stream_is_record()
95 pub async fn write_ping_request(&mut self, timestamp: u32) -> Result<(), EventMessagesError> { in write_ping_request()
106 pub async fn write_ping_response(&mut self, timestamp: u32) -> Result<(), EventMessagesError> { in write_ping_response()
/xiu/protocol/rtmp/src/amf0/
H A Damf0_writer.rs20 pub fn write_anys(&mut self, values: &Vec<Amf0ValueType>) -> Result<(), Amf0WriteError> { in write_anys()
27 pub fn write_any(&mut self, value: &Amf0ValueType) -> Result<(), Amf0WriteError> { in write_any()
39 pub fn write_number(&mut self, value: &f64) -> Result<(), Amf0WriteError> { in write_number()
45 pub fn write_bool(&mut self, value: &bool) -> Result<(), Amf0WriteError> { in write_bool()
51 pub fn write_string(&mut self, value: &String) -> Result<(), Amf0WriteError> { in write_string()
65 pub fn write_null(&mut self) -> Result<(), Amf0WriteError> { in write_null()
70 pub fn write_object_eof(&mut self) -> Result<(), Amf0WriteError> { in write_object_eof()
79 ) -> Result<(), Amf0WriteError> { in write_object()
95 ) -> Result<(), Amf0WriteError> { in write_eacm_array()
/xiu/library/bytesio/src/
H A Dbytes_writer.rs29 pub fn write_u8(&mut self, byte: u8) -> Result<(), BytesWriteError> { in write_u8()
34 pub fn or_u8_at(&mut self, position: usize, byte: u8) -> Result<(), BytesWriteError> { in or_u8_at()
45 pub fn add_u8_at(&mut self, position: usize, byte: u8) -> Result<(), BytesWriteError> { in add_u8_at()
71 pub fn write_u16<T: ByteOrder>(&mut self, bytes: u16) -> Result<(), BytesWriteError> { in write_u16()
97 pub fn write(&mut self, buf: &[u8]) -> Result<(), BytesWriteError> { in write()
102 pub fn prepend(&mut self, buf: &[u8]) -> Result<(), BytesWriteError> { in prepend()
114 pub fn write_random_bytes(&mut self, length: u32) -> Result<(), BytesWriteError> { in write_random_bytes()
167 pub fn write_u8(&mut self, byte: u8) -> Result<(), BytesWriteError> { in write_u8()
187 pub fn write(&mut self, buf: &[u8]) -> Result<(), BytesWriteError> { in write()
191 pub fn write_random_bytes(&mut self, length: u32) -> Result<(), BytesWriteError> { in write_random_bytes()
[all …]
H A Dbits_writer.rs24 pub fn write_bytes(&mut self, data: BytesMut) -> Result<(), BitError> { in write_bytes()
29 pub fn write_bit(&mut self, b: u8) -> Result<(), BitError> { in write_bit()
42 pub fn write_8bit(&mut self, b: u8) -> Result<(), BitError> { in write_8bit()
53 fn flush(&mut self) -> Result<(), BitError> { in flush()
66 pub fn write_n_bits(&mut self, data: u64, bit_num: usize) -> Result<(), BitError> { in write_n_bits()
109 pub fn bits_aligment_8(&mut self) -> Result<(), BitError> { in bits_aligment_8()
/xiu/protocol/rtmp/src/netstream/
H A Dwriter.rs49 ) -> Result<(), NetStreamError> { in write_play()
64 ) -> Result<(), NetStreamError> { in write_delete_stream()
78 ) -> Result<(), NetStreamError> { in write_close_stream()
92 ) -> Result<(), NetStreamError> { in write_release_stream()
106 ) -> Result<(), NetStreamError> { in write_fcpublish()
120 ) -> Result<(), NetStreamError> { in write_receive_audio()
134 ) -> Result<(), NetStreamError> { in write_receive_video()
148 ) -> Result<(), NetStreamError> { in write_publish()
172 ) -> Result<(), NetStreamError> { in write_pause()
187 ) -> Result<(), NetStreamError> { in write_on_bw_done()
[all …]
/xiu/protocol/rtmp/src/protocol_control_messages/
H A Dwriter.rs19 ) -> Result<(), ControlMessagesError> { in write_control_message_header()
36 ) -> Result<(), ControlMessagesError> { in write_set_chunk_size()
48 ) -> Result<(), ControlMessagesError> { in write_abort_message()
59 ) -> Result<(), ControlMessagesError> { in write_acknowledgement()
70 ) -> Result<(), ControlMessagesError> { in write_window_acknowledgement_size()
82 ) -> Result<(), ControlMessagesError> { in write_set_peer_bandwidth()
/xiu/application/xiu/src/
H A Dservice.rs30 pub async fn run(&mut self) -> Result<()> { in run()
63 async fn start_http_api_server(&mut self, stream_hub: &mut StreamsHub) -> Result<()> { in start_http_api_server()
78 async fn start_rtmp(&mut self, stream_hub: &mut StreamsHub) -> Result<()> { in start_rtmp()
160 async fn start_rtmp_remuxer(&mut self, stream_hub: &mut StreamsHub) -> Result<()> { in start_rtmp_remuxer()
195 async fn start_rtsp(&mut self, stream_hub: &mut StreamsHub) -> Result<()> { in start_rtsp()
219 async fn start_webrtc(&mut self, stream_hub: &mut StreamsHub) -> Result<()> { in start_webrtc()
243 async fn start_httpflv(&mut self, stream_hub: &mut StreamsHub) -> Result<()> { in start_httpflv()
263 async fn start_hls(&mut self, stream_hub: &mut StreamsHub) -> Result<()> { in start_hls()
/xiu/protocol/rtmp/src/session/
H A Dclient_session.rs145 pub async fn run(&mut self) -> Result<(), SessionError> { in run()
210 async fn handshake(&mut self) -> Result<(), SessionError> { in handshake()
235 ) -> Result<(), SessionError> { in process_messages()
287 ) -> Result<(), SessionError> { in on_amf0_command_message()
388 ) -> Result<(), SessionError> { in send_delete_stream()
402 ) -> Result<(), SessionError> { in send_publish()
418 ) -> Result<(), SessionError> { in send_play()
444 ) -> Result<(), SessionError> { in send_window_acknowledgement_size()
457 ) -> Result<(), SessionError> { in send_set_buffer_length()
516 pub fn on_error(&mut self) -> Result<(), SessionError> { in on_error()
[all …]
H A Dcommon.rs150 ) -> Result<(), SessionError> { in send_metadata()
172 ) -> Result<(), SessionError> { in on_video_data()
199 ) -> Result<(), SessionError> { in on_audio_data()
226 ) -> Result<(), SessionError> { in on_meta_data()
300 ) -> Result<(), SessionError> { in subscribe_from_channels()
339 ) -> Result<(), SessionError> { in unsubscribe_from_channels()
363 ) -> Result<(), SessionError> { in publish_to_channels()
395 ) -> Result<(), SessionError> { in unpublish_to_channels()
457 ) -> Result<(), CacheError> { in save_video_data()
468 ) -> Result<(), CacheError> { in save_audio_data()
[all …]
H A Dserver_session.rs103 pub async fn run(&mut self) -> Result<(), SessionError> { in run()
124 async fn handshake(&mut self) -> Result<(), SessionError> { in handshake()
150 async fn read_parse_chunks(&mut self) -> Result<(), SessionError> { in read_parse_chunks()
215 async fn play(&mut self) -> Result<(), SessionError> { in play()
233 pub async fn send_set_chunk_size(&mut self) -> Result<(), SessionError> { in send_set_chunk_size()
246 ) -> Result<(), SessionError> { in process_messages()
288 ) -> Result<(), SessionError> { in on_amf0_command_message()
426 ) -> Result<(), SessionError> { in on_connect()
495 ) -> Result<(), SessionError> { in on_delete_stream()
539 ) -> Result<(), SessionError> { in on_play()
[all …]
/xiu/library/container/flv/src/
H A Dmuxer.rs32 pub fn write_flv_header(&mut self) -> Result<(), FlvMuxerError> { in write_flv_header()
42 ) -> Result<(), FlvMuxerError> { in write_flv_tag_header()
58 pub fn write_flv_tag_body(&mut self, body: BytesMut) -> Result<(), FlvMuxerError> { in write_flv_tag_body()
63 pub fn write_previous_tag_size(&mut self, size: u32) -> Result<(), FlvMuxerError> { in write_previous_tag_size()
/xiu/protocol/httpflv/src/
H A Dhttpflv.rs64 pub async fn run(&mut self) -> Result<(), HttpFLvError> { in run()
71 pub async fn send_media_stream(&mut self) -> Result<(), HttpFLvError> { in send_media_stream()
102 pub fn write_flv_tag(&mut self, channel_data: FrameData) -> Result<(), HttpFLvError> { in write_flv_tag()
132 pub fn flush_response_data(&mut self) -> Result<(), HttpFLvError> { in flush_response_data()
139 pub async fn unsubscribe_from_rtmp_channels(&mut self) -> Result<(), HttpFLvError> { in unsubscribe_from_rtmp_channels()
166 pub async fn subscribe_from_rtmp_channels(&mut self) -> Result<(), HttpFLvError> { in subscribe_from_rtmp_channels()
H A Dserver.rs14 type Result<T> = std::result::Result<T, GenericError>; typedef
63 pub async fn run(event_producer: StreamHubEventSender, port: usize) -> Result<()> { in run()
/xiu/protocol/hls/src/
H A Dflv_data_receiver.rs54 pub async fn run(&mut self) -> Result<(), HlsError> { in run()
62 pub async fn receive_flv_data(&mut self) -> Result<(), HlsError> { in receive_flv_data()
91 pub fn flush_response_data(&mut self) -> Result<(), HlsError> { in flush_response_data()
99 ) -> Result<(), HlsError> { in subscribe_from_rtmp_channels()
141 pub async fn unsubscribe_from_rtmp_channels(&mut self) -> Result<(), HlsError> { in unsubscribe_from_rtmp_channels()
H A Dflv2hls.rs67 pub fn process_flv_data(&mut self, data: FlvData) -> Result<(), MediaError> { in process_flv_data()
88 pub fn flush_remaining_data(&mut self) -> Result<(), MediaError> { in flush_remaining_data()
108 ) -> Result<(), MediaError> { in process_demux_data()
170 pub fn clear_files(&mut self) -> Result<(), MediaError> { in clear_files()
/xiu/protocol/rtmp/src/netconnection/
H A Dwriter.rs77 async fn write_chunk(&mut self) -> Result<(), NetConnectionError> { in write_chunk()
97 ) -> Result<(), NetConnectionError> { in write_connect_with_value()
109 ) -> Result<(), NetConnectionError> { in write_connect()
194 ) -> Result<(), NetConnectionError> { in write_connect_response()
238 ) -> Result<(), NetConnectionError> { in write_create_stream()
251 ) -> Result<(), NetConnectionError> { in write_create_stream_response()
264 ) -> Result<(), NetConnectionError> { in write_get_stream_length()
280 ) -> Result<(), NetConnectionError> { in error()
/xiu/protocol/rtsp/src/session/
H A Dmod.rs128 pub async fn run(&mut self) -> Result<(), SessionError> { in run()
157 ) -> Result<(), SessionError> { in on_rtp_over_rtsp_message()
177 async fn on_rtsp_message(&mut self) -> Result<(), SessionError> { in on_rtsp_message()
217 async fn handle_options(&mut self, rtsp_request: &RtspRequest) -> Result<(), SessionError> { in handle_options()
227 async fn handle_describe(&mut self, rtsp_request: &RtspRequest) -> Result<(), SessionError> { in handle_describe()
326 async fn handle_setup(&mut self, rtsp_request: &RtspRequest) -> Result<(), SessionError> { in handle_setup()
413 async fn handle_play(&mut self, rtsp_request: &RtspRequest) -> Result<(), SessionError> { in handle_play()
563 fn handle_teardown(&mut self, rtsp_request: &RtspRequest) -> Result<(), SessionError> { in handle_teardown()
590 fn new_tracks(&mut self) -> Result<(), SessionError> { in new_tracks()
697 async fn send_response(&mut self, response: &RtspResponse) -> Result<(), SessionError> { in send_response()
[all …]
/xiu/protocol/rtmp/src/chunk/
H A Dpacketizer.rs86 fn write_basic_header(&mut self, fmt: u8, csid: u32) -> Result<(), PackError> { in write_basic_header()
104 ) -> Result<(), PackError> { in write_message_header()
163 fn write_extened_timestamp(&mut self, timestamp: u32) -> Result<(), PackError> { in write_extened_timestamp()
169 pub async fn write_chunk(&mut self, chunk_info: &mut ChunkInfo) -> Result<(), PackError> { in write_chunk()
/xiu/protocol/rtsp/src/rtp/
H A Drtp_h264.rs55 pub async fn pack_fu_a(&mut self, nalu: BytesMut) -> Result<(), PackerError> { in pack_fu_a()
101 pub async fn pack_single(&mut self, nalu: BytesMut) -> Result<(), PackerError> { in pack_single()
124 async fn pack(&mut self, nalus: &mut BytesMut, timestamp: u32) -> Result<(), PackerError> { in pack()
143 async fn pack_nalu(&mut self, nalu: BytesMut) -> Result<(), PackerError> { in pack_nalu()
163 fn unpack(&mut self, reader: &mut BytesReader) -> Result<(), UnPackerError> { in unpack()
210 ) -> Result<(), UnPackerError> { in unpack_single()
268 ) -> Result<(), UnPackerError> { in unpack_fu()
348 ) -> Result<(), UnPackerError> { in unpack_stap()
432 ) -> Result<(), UnPackerError> { in unpack_mtap()
H A Drtp_h265.rs55 pub async fn pack_fu(&mut self, nalu: BytesMut) -> Result<(), PackerError> { in pack_fu()
123 pub async fn pack_single(&mut self, nalu: BytesMut) -> Result<(), PackerError> { in pack_single()
143 async fn pack(&mut self, nalus: &mut BytesMut, timestamp: u32) -> Result<(), PackerError> { in pack()
161 async fn pack_nalu(&mut self, nalu: BytesMut) -> Result<(), PackerError> { in pack_nalu()
182 fn unpack(&mut self, reader: &mut BytesReader) -> Result<(), UnPackerError> { in unpack()
221 fn unpack_single(&mut self, payload: BytesMut) -> Result<(), UnPackerError> { in unpack_single()
259 fn unpack_ap(&mut self, rtp_payload: BytesMut) -> Result<(), UnPackerError> { in unpack_ap()
322 fn unpack_fu(&mut self, rtp_payload: BytesMut) -> Result<(), UnPackerError> { in unpack_fu()
/xiu/protocol/rtmp/src/remuxer/
H A Drtsp2rtmp.rs87 pub async fn run(&mut self) -> Result<(), RtmpRemuxerError> { in run()
95 pub async fn publish_rtmp(&mut self) -> Result<(), RtmpRemuxerError> { in publish_rtmp()
107 pub async fn unpublish_rtmp(&mut self) -> Result<(), RtmpRemuxerError> { in unpublish_rtmp()
118 pub async fn subscribe_rtsp(&mut self) -> Result<(), RtmpRemuxerError> { in subscribe_rtsp()
150 pub async fn unsubscribe_rtsp(&mut self) -> Result<(), RtmpRemuxerError> { in unsubscribe_rtsp()
174 pub async fn receive_rtsp_data(&mut self) -> Result<(), RtmpRemuxerError> { in receive_rtsp_data()
227 ) -> Result<(), RtmpRemuxerError> { in on_rtsp_audio()
262 ) -> Result<(), RtmpRemuxerError> { in on_rtsp_video()
/xiu/protocol/webrtc/src/session/
H A Dmod.rs68 pub async fn close_peer_connection(&self) -> Result<(), SessionError> { in close_peer_connection()
78 ) -> Result<(), SessionError> { in run()
252 ) -> Result<(), SessionError> { in publish_whip()
303 ) -> Result<(), SessionError> { in unpublish_whip()
327 ) -> Result<(), SessionError> { in subscribe_whep()
416 ) -> Result<(), SessionError> { in unsubscribe_whep()
502 async fn send_response(&mut self, response: &HttpResponse) -> Result<(), SessionError> { in send_response()
524 ) -> Result<(), ChannelError> { in send_prior_data()

1234