Searched refs:streams (Results 1 – 11 of 11) sorted by relevance
20 pub streams: Vec<pes::Pes>, field38 streams: Vec::new(), in new()83 for stream in &pmt.streams { in write()
82 let cur_stream = cur_pmt.streams.get_mut(self.cur_stream_index).unwrap(); in write()173 let stream_data = cur_pmt.streams.get_mut(self.cur_stream_index).unwrap(); in write_pes()213 let stream_data = cur_pmt.streams.get_mut(self.cur_stream_index).unwrap(); in write_ts_header_for_pes()327 for stream in pmt.streams.iter_mut() { in find_stream()372 if pmt.streams.len() == 4 { in pmt_add_stream()396 pmt.streams.push(cur_stream); in pmt_add_stream()
3 description = "It receives streams from publishers(rtmp/rtsp etc.) and send streams to subscribers(…
9 # pull streams from other server node.14 # push streams to other server node.
261 streams: HashMap<StreamIdentifier, TransmitterEventSender>, field288 streams: HashMap::new(), in new()522 if let Some(producer) = self.streams.get_mut(identifier) { in request()538 for v in self.streams.values() { in api_statistic()599 if let Some(producer) = self.streams.get_mut(identifer) { in subscribe()637 match self.streams.get_mut(identifer) { in unsubscribe()662 if self.streams.get(&identifier).is_some() { in publish()683 self.streams.insert(identifier.clone(), event_publisher); in publish()700 match self.streams.get_mut(identifier) { in unpublish()706 self.streams.remove(identifier); in unpublish()
38 - [x] Support publishing or subscribing H.264/AAC streams.54 - [x] Support recording live streams into HLS files(m3u8+ts).139 # pull streams from other server node.145 # push streams to other server node.
137 # pull streams from other server node.143 # push streams to other server node.
33 - [x] Support publishing or subscribing H.264/AAC streams.49 - [x] Support recording live streams into HLS files(m3u8+ts).134 # pull streams from other server node.140 # push streams to other server node.
9 …You can use this library to push or pull RTMP streams , refer to the pprtmp example from xiu/appli…