Lines Matching refs:new
41 internal: Arc::new(ReceiverReportInternal { in build_rr()
48 streams: Mutex::new(HashMap::new()), in build_rr()
49 close_rx: Mutex::new(Some(close_rx)), in build_rr()
52 wg: Mutex::new(Some(WaitGroup::new())), in build_rr()
53 close_tx: Mutex::new(Some(close_tx)), in build_rr()
60 internal: Arc::new(SenderReportInternal { in build_sr()
67 streams: Mutex::new(HashMap::new()), in build_sr()
68 close_rx: Mutex::new(Some(close_rx)), in build_sr()
71 wg: Mutex::new(Some(WaitGroup::new())), in build_sr()
72 close_tx: Mutex::new(Some(close_tx)), in build_sr()
80 Ok(Arc::new(self.build_rr())) in build()
82 Ok(Arc::new(self.build_sr())) in build()