| /xiu/application/xiu/src/ |
| H A D | main.rs | 112 Ok(val) => val, in main()
129 Some(val) => *val, in main()
134 Some(val) => *val, in main()
139 Some(val) => *val, in main()
144 Some(val) => *val, in main()
148 Some(val) => *val, in main()
152 Some(val) => val.clone(), in main()
|
| /xiu/protocol/rtmp/src/amf0/ |
| H A D | amf0_writer.rs | 21 for val in values { in write_anys()
22 self.write_any(val)?; in write_anys()
29 Amf0ValueType::Boolean(ref val) => self.write_bool(val), in write_any()
31 Amf0ValueType::Number(ref val) => self.write_number(val), in write_any()
32 Amf0ValueType::UTF8String(ref val) => self.write_string(val), in write_any()
33 Amf0ValueType::Object(ref val) => self.write_object(val), in write_any()
34 Amf0ValueType::EcmaArray(ref val) => self.write_eacm_array(val), in write_any()
|
| H A D | amf0_reader.rs | 87 let val = String::from_utf8(bytes.to_vec())?; in read_raw_string() localVariable
89 Ok(val) in read_raw_string()
121 let val = self.read_any()?; in read_object() localVariable
123 properties.insert(key, val); in read_object()
138 let val = self.read_any()?; in read_ecma_array() localVariable
139 properties.insert(key, val); in read_ecma_array()
154 let val = String::from_utf8(buff.to_vec())?; in read_long_string() localVariable
155 Ok(Amf0ValueType::LongUTF8String(val)) in read_long_string()
|
| /xiu/protocol/rtmp/src/remuxer/ |
| H A D | mod.rs | 29 let val = self.receiver.recv().await?; in run() localVariable
30 log::info!("{:?}", val); in run()
31 match val { in run()
|
| /xiu/library/bytesio/src/ |
| H A D | bytes_reader.rs | 83 let val = cursor.read_u16::<T>()?; in read_u16() localVariable
84 Ok(val) in read_u16()
89 let val = cursor.read_u24::<T>()?; in read_u24() localVariable
90 Ok(val) in read_u24()
100 let val = cursor.read_u32::<T>()?; in read_u32() localVariable
102 Ok(val) in read_u32()
107 let val = cursor.read_u48::<T>()?; in read_u48() localVariable
109 Ok(val) in read_u48()
114 let val = cursor.read_f64::<T>()?; in read_f64() localVariable
116 Ok(val) in read_f64()
[all …]
|
| H A D | bytesio_errors.rs | 25 fn from(val: BytesIOErrorValue) -> Self { in from()
26 BytesIOError { value: val } in from()
|
| H A D | bits_errors.rs | 25 fn from(val: BitErrorValue) -> Self { in from()
26 BitError { value: val } in from()
|
| H A D | bytes_errors.rs | 30 fn from(val: BytesReadErrorValue) -> Self { in from()
31 BytesReadError { value: val } in from()
|
| H A D | bytes_writer.rs | 260 if let Ok(val) = rv { in test_write_vec()
271 let val = ((pts << 1) & 0xFE) as u8; in test_bit_opertion() localVariable
|
| /xiu/protocol/rtmp/src/chunk/ |
| H A D | errors.rs | 26 fn from(val: UnpackErrorValue) -> Self { in from()
27 UnpackError { value: val } in from()
55 fn from(val: PackErrorValue) -> Self { in from()
56 PackError { value: val } in from()
|
| /xiu/protocol/hls/src/ |
| H A D | remuxer.rs | 30 let val = self.client_event_consumer.recv().await?; in run() localVariable
31 match val { in run()
|
| /xiu/protocol/rtsp/src/ |
| H A D | rtsp_transport.rs | 83 if let Some(val) = vals.0 { in unmarshal()
84 interleaveds[0] = val; in unmarshal()
86 if let Some(val) = vals.1 { in unmarshal()
87 interleaveds[1] = val; in unmarshal()
|
| /xiu/application/xiu/src/config/ |
| H A D | mod.rs | 183 Ok(val) => println!("The current directory is {}\n", val.display()), in test_toml_parse()
192 Ok(val) => { in test_toml_parse()
194 let decoded: Config = toml::from_str(&val[..]).unwrap(); in test_toml_parse()
198 if let Some(val) = rtmp { in test_toml_parse()
|
| /xiu/protocol/rtmp/src/messages/ |
| H A D | parser.rs | 47 Ok(val) => val, in parse()
169 Ok(val) => val, in test_message_parse()
|
| H A D | errors.rs | 34 fn from(val: MessageErrorValue) -> Self { in from()
35 MessageError { value: val } in from()
|
| /xiu/protocol/rtmp/src/relay/ |
| H A D | push_client.rs | 35 let val = self.client_event_consumer.recv().await?; in run() localVariable
37 match val { in run()
|
| /xiu/protocol/rtmp/src/session/ |
| H A D | server_session.rs | 554 Amf0ValueType::UTF8String(val) => Some(val), in on_play()
563 Amf0ValueType::Number(val) => Some(val), in on_play()
572 Amf0ValueType::Number(val) => Some(val), in on_play()
581 Amf0ValueType::Boolean(val) => Some(val), in on_play()
678 Amf0ValueType::UTF8String(val) => val, in on_publish()
694 Amf0ValueType::UTF8String(val) => val, in on_publish()
|
| /xiu/library/streamhub/src/ |
| H A D | utils.rs | 101 let val: String = self in fmt() localVariable
106 write!(f, "{}", &val) in fmt()
|
| H A D | lib.rs | 66 if let Some(val) = data { in receive_frame_data_loop()
67 match val { in receive_frame_data_loop()
120 if let Some(val) = data { in receive_packet_data_loop()
121 match val { in receive_packet_data_loop()
170 if let Some(val) = receiver.recv().await { in receive_event_loop()
171 match val { in receive_event_loop()
|
| /xiu/protocol/rtmp/src/handshake/ |
| H A D | errors.rs | 39 fn from(val: HandshakeErrorValue) -> Self { in from()
40 HandshakeError { value: val } in from()
|
| /xiu/protocol/rtsp/src/sdp/ |
| H A D | mod.rs | 254 let attr_value = if let Some(val) = attribute.get(1) { in unmarshal()
255 val in unmarshal()
|
| /xiu/protocol/rtsp/src/http/ |
| H A D | mod.rs | 40 if let Some(val) = url.strip_prefix("rtsp://") { in unmarshal()
41 if let Some(index) = val.find('/') { in unmarshal()
|