| /webrtc/constraints/src/algorithms/select_settings/ |
| H A D | apply_advanced.rs | 86 .map(|settings| (settings, 42.0)) in overconstrained()
103 .map(|(settings, _)| settings) in overconstrained()
153 let candidates: Vec<_> = settings.iter().map(|settings| (settings, 42.0)).collect(); in constrained()
183 .map(|(settings, _)| settings) in constrained()
|
| /webrtc/constraints/src/constraints/ |
| H A D | constraint_set.rs | 81 Self::new(iter.into_iter().map(|(k, v)| (k.into(), v)).collect()) in from_iter()
87 type IntoIter = indexmap::map::IntoIter<MediaTrackProperty, T>;
108 .map(|(property, constraint)| (property, constraint.into_resolved(strategy))) in into_resolved()
132 .map(|constraint| (property, constraint)) in into_sanitized()
|
| H A D | advanced.rs | 101 .map(|constraint_set| constraint_set.into_resolved(strategy)), in into_resolved()
120 .map(|constraint_set| constraint_set.into_sanitized(supported_constraints)) in into_sanitized()
|
| H A D | mandatory.rs | 132 Self::new(iter.into_iter().map(|(k, v)| (k.into(), v)).collect()) in from_iter()
138 type IntoIter = indexmap::map::IntoIter<MediaTrackProperty, T>;
|
| /webrtc/media/benches/ |
| H A D | audio_buffer.rs | 13 let samples = (0..(channels * frames)).map(|i| i as i32).collect(); in benchmark_from()
17 let samples = (0..(channels * frames)).map(|i| i as i32).collect(); in benchmark_from()
|
| /webrtc/constraints/src/ |
| H A D | supported_constraints.rs | 83 Self(iter.into_iter().map(|property| property.into()).collect()) in from_iter()
112 let mut map = serializer.serialize_map(Some(self.0.len()))?; in serialize() localVariable
114 map.serialize_entry(property, &true)?; in serialize()
116 map.end() in serialize()
|
| /webrtc/interceptor/src/ |
| H A D | registry.rs | 31 .map(|c| Arc::new(c) as Arc<dyn Interceptor + Send + Sync>) in build()
40 let interceptors: Result<Vec<_>> = self.builders.iter().map(|b| b.build(id)).collect(); in build_chain()
|
| H A D | error.rs | 43 let errs_strs: Vec<String> = errs.into_iter().map(|e| e.to_string()).collect(); in flatten_errs()
|
| /webrtc/media/src/io/sample_builder/ |
| H A D | mod.rs | 62 prepared_samples: (0..=u16::MAX as usize).map(|_| None).collect(), in new()
247 let is_same_timestamp = head_timestamp.map(|t| packet.header.timestamp == t); in build_sample()
248 let is_different_timestamp = is_same_timestamp.map(std::ops::Not::not); in build_sample()
301 .map(|p| &p.payload) in build_sample()
307 p.map(|p| { in build_sample()
333 .map(|p| &p.payload) in build_sample()
|
| H A D | sample_sequence_location_test.rs | 39 let reconstructed: Vec<_> = s.range(&data).map(|x| x.cloned()).collect(); in test_sample_sequence_location_range()
|
| /webrtc/webrtc/src/peer_connection/policy/ |
| H A D | sdp_semantics.rs | 89 .map(|md| md.media_name.media.clone()) in get_md_names()
107 .map(|ssrc| ssrc.to_owned()) in extract_ssrc_list()
|
| /webrtc/interceptor/src/stats/ |
| H A D | interceptor.rs | 192 … .map(|ssrc| ssrc_stats.get_inbound_stats(ssrc).map(inbound::StreamStats::snapshot)) in run_stats_reducer()
200 … .map(|ssrc| ssrc_stats.get_outbound_stats(ssrc).map(outbound::StreamStats::snapshot)) in run_stats_reducer()
471 e.generic_rtcp.fir_count.map(|v| v + 1).or(Some(1)); in read()
488 .map(|e| e.sr_packets_sent.is_some()) in read()
509 dlrr.map(|b| b.reports.iter()).into_iter().flatten() in read()
518 .map(|e| e.dlrr_last_rr.is_some()) in read()
564 let futures = receiver_reports.into_iter().map(|rr| { in read()
581 let futures = sender_reports.into_iter().map(|sr| { in read()
594 .and_then(|ps| sr.sr_bytes_sent.map(|bs| (ps, bs))), in read()
638 e.fir_count = e.fir_count.map(|v| v + 1).or(Some(1)); in write()
[all …]
|
| /webrtc/mdns/src/message/ |
| H A D | message_test.rs | 418 Box::new(|p: &mut Parser<'_>| -> Result<()> { p.resource_body().map(|_| ()) }), in test_resource_not_started()
422 Box::new(|p: &mut Parser<'_>| -> Result<()> { p.resource_body().map(|_| ()) }), in test_resource_not_started()
426 Box::new(|p: &mut Parser<'_>| -> Result<()> { p.resource_body().map(|_| ()) }), in test_resource_not_started()
430 Box::new(|p: &mut Parser<'_>| -> Result<()> { p.resource_body().map(|_| ()) }), in test_resource_not_started()
434 Box::new(|p: &mut Parser<'_>| -> Result<()> { p.resource_body().map(|_| ()) }), in test_resource_not_started()
438 Box::new(|p: &mut Parser<'_>| -> Result<()> { p.resource_body().map(|_| ()) }), in test_resource_not_started()
612 Box::new(|p: &mut Parser<'_>| -> Result<()> { p.question().map(|_| ()) }), in test_skip_after_read()
616 Box::new(|p: &mut Parser<'_>| -> Result<()> { p.answer().map(|_| ()) }), in test_skip_after_read()
620 Box::new(|p: &mut Parser<'_>| -> Result<()> { p.authority().map(|_| ()) }), in test_skip_after_read()
624 Box::new(|p: &mut Parser<'_>| -> Result<()> { p.additional().map(|_| ()) }), in test_skip_after_read()
[all …]
|
| H A D | mod.rs | 249 let v: Vec<String> = self.questions.iter().map(|q| q.to_string()).collect(); in fmt()
253 let v: Vec<String> = self.answers.iter().map(|q| q.to_string()).collect(); in fmt()
257 let v: Vec<String> = self.authorities.iter().map(|q| q.to_string()).collect(); in fmt()
261 let v: Vec<String> = self.additionals.iter().map(|q| q.to_string()).collect(); in fmt()
|
| /webrtc/ice/src/udp_mux/ |
| H A D | udp_mux_conn.rs | 169 .map(u16::from_le_bytes) in recv_from()
170 .map(From::from) in recv_from()
184 .map(u16::from_le_bytes) in recv_from()
185 .map(From::from) in recv_from()
|
| /webrtc/dtls/src/crypto/ |
| H A D | crypto_test.rs | 193 .map(|x| x.0.clone()) in test_certificate_verify()
215 .map(|x| x.0.clone()) in test_certificate_verify()
|
| /webrtc/ice/src/rand/ |
| H A D | mod.rs | 18 .map(|_| { in generate_crypto_random_string()
|
| /webrtc/dtls/src/fragment_buffer/ |
| H A D | mod.rs | 131 .map(|fragment| fragment.iter().map(|f| f.data.len()).sum::<usize>()) in size()
|
| /webrtc/constraints/src/algorithms/fitness_distance/ |
| H A D | settings.rs | 20 .map(|(property, constraint)| { in fitness_distance()
|
| /webrtc/rtp/src/codecs/g7xx/ |
| H A D | g7xx_test.rs | 11 let samples: Vec<u8> = (0..TEST_LEN).map(|_| rand::random::<u8>()).collect(); in test_g7xx_payload()
|
| /webrtc/util/src/vnet/ |
| H A D | chunk_queue.rs | 41 chunks.front().map(|chunk| chunk.clone_to()) in peek()
|
| /webrtc/srtp/src/context/ |
| H A D | mod.rs | 184 self.srtp_ssrc_states.get(&ssrc).map(|s| s.rollover_counter) in get_roc()
196 self.srtcp_ssrc_states.get(&ssrc).map(|s| s.srtcp_index) in get_index()
|
| /webrtc/rtp/src/ |
| H A D | header.rs | 325 .map(|extension| extension.payload.len()) in get_extension_payload_len()
393 self.extensions.iter().map(|e| e.id).collect() in get_extension_ids()
405 .map(|extension| extension.payload.clone()) in get_extension()
|
| /webrtc/sctp/src/param/ |
| H A D | param_supported_extensions.rs | 19 .map(|ct| ct.to_string()) in fmt()
|
| H A D | param_chunk_list.rs | 19 .map(|ct| ct.to_string()) in fmt()
|