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()
475                     e.generic_rtcp.pli_count = e.generic_rtcp.pli_count.map(|v| v + 1).or(Some(1));  in read()
481                         e.generic_rtcp.nack_count.map(|v| v + count).or(Some(count));  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()
642                     e.pli_count = e.pli_count.map(|v| v + 1).or(Some(1));  in write()
647                     e.nack_count = e.nack_count.map(|v| v + count).or(Some(count));  in write()