| /xiu/protocol/hls/src/ |
| H A D | server.rs | 25 let rv: Vec<_> = left.split('/').collect(); in handle_connection() localVariable
27 let app_name = String::from(rv[1]); in handle_connection()
28 let stream_name = String::from(rv[2]); in handle_connection()
39 let rv: Vec<_> = left.split('/').collect(); in handle_connection() localVariable
41 let app_name = String::from(rv[1]); in handle_connection()
42 let stream_name = String::from(rv[2]); in handle_connection()
43 let ts_name = String::from(rv[3]); in handle_connection()
|
| H A D | flv_data_receiver.rs | 124 let rv = self.event_producer.send(subscribe_event); in subscribe_from_rtmp_channels() localVariable
125 if rv.is_err() { in subscribe_from_rtmp_channels()
|
| /xiu/library/bytesio/src/ |
| H A D | bytes_reader.rs | 258 assert_eq!(rv, 1, "Incorrect value"); in test_rc_refcell()
260 rv = reader.borrow_mut().read_u8().unwrap(); in test_rc_refcell()
261 assert_eq!(rv, 2, "Incorrect value"); in test_rc_refcell()
263 rv = reader.borrow_mut().read_u8().unwrap(); in test_rc_refcell()
264 assert_eq!(rv, 3, "Incorrect value"); in test_rc_refcell()
296 let mut rv = reader.read_u8().unwrap(); in test_struct_rc_refcell() localVariable
297 assert_eq!(rv, 1, "Incorrect value"); in test_struct_rc_refcell()
299 rv = reader.read_u8().unwrap(); in test_struct_rc_refcell()
300 assert_eq!(rv, 2, "Incorrect value"); in test_struct_rc_refcell()
302 rv = reader.read_u8().unwrap(); in test_struct_rc_refcell()
[all …]
|
| H A D | bytesio.rs | 85 let mut rv = BytesMut::new(); in read() localVariable
86 rv.put(&buf[..len]); in read()
88 Ok(rv) in read()
|
| H A D | bytes_writer.rs | 258 let rv = v.write(&FLV_HEADER); in test_write_vec() localVariable
260 if let Ok(val) = rv { in test_write_vec()
|
| /xiu/protocol/httpflv/src/ |
| H A D | server.rs | 27 let rv: Vec<_> = left.split('/').collect(); in handle_connection() localVariable
29 let app_name = String::from(rv[1]); in handle_connection()
30 let stream_name = String::from(rv[2]); in handle_connection()
|
| H A D | httpflv.rs | 190 let rv = self.event_producer.send(subscribe_event); in subscribe_from_rtmp_channels() localVariable
191 if rv.is_err() { in subscribe_from_rtmp_channels()
|
| /xiu/library/logger/src/ |
| H A D | target.rs | 22 Ok(rv) => Ok(rv), in write()
|
| /xiu/protocol/rtmp/src/handshake/ |
| H A D | digest.rs | 121 let mut rv = BytesMut::new(); in make_digest() localVariable
122 rv.extend_from_slice(result.as_slice()); in make_digest()
124 Ok(rv) in make_digest()
|
| /xiu/protocol/rtmp/src/messages/ |
| H A D | parser.rs | 168 let rv = match result { in test_message_parse() localVariable
176 if let UnpackResult::ChunkInfo(chunk_info) = rv { in test_message_parse()
|
| /xiu/library/container/flv/src/ |
| H A D | mpeg4_aac.rs | 369 let rv = (pce_bits_vec.len() + 7) / 8; in pce_load() localVariable
380 Ok(rv as u8) in pce_load()
|
| /xiu/protocol/rtmp/src/chunk/ |
| H A D | unpacketizer.rs | 658 let rv = unpacker.read_chunk(); in test_set_chunk_size() localVariable
668 rv.unwrap(), in test_set_chunk_size()
|
| /xiu/protocol/rtmp/src/session/ |
| H A D | common.rs | 320 let rv = self.event_producer.send(subscribe_event); in subscribe_from_channels() localVariable
322 if rv.is_err() { in subscribe_from_channels()
|
| H A D | client_session.rs | 189 Ok(rv) => { in run()
190 if let UnpackResult::Chunks(chunks) = rv { in run()
|
| H A D | server_session.rs | 184 Ok(rv) => { in read_parse_chunks()
185 if let UnpackResult::Chunks(chunks) = rv { in read_parse_chunks()
|
| /xiu/library/streamhub/src/ |
| H A D | lib.rs | 460 let rv = match self.subscribe(&identifier, info_clone, sender).await { in event_loop() localVariable
481 if result_sender.send(rv).is_err() { in event_loop()
|
| /xiu/protocol/rtsp/src/session/ |
| H A D | mod.rs | 572 let rv = self.event_producer.send(unpublish_event); in handle_teardown() localVariable
573 match rv { in handle_teardown()
|