Home
last modified time | relevance | path

Searched refs:Sync (Results 1 – 21 of 21) sorted by relevance

/xiu/protocol/rtsp/src/rtp/
H A Dutils.rs26 pub type OnFrameFn = Box<dyn Fn(FrameData) -> Result<(), UnPackerError> + Send + Sync>;
32 Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>,
36 + Sync,
40 Box<dyn Fn(RtpPacket) -> Pin<Box<dyn Future<Output = ()> + Send + 'static>> + Send + Sync>;
48 pub trait TPacker: TRtpReceiverForRtcp + Send + Sync {
61 pub trait TUnPacker: TRtpReceiverForRtcp + Send + Sync {
H A Drtp_aac.rs29 io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>,
37 io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, in new() argument
H A Drtp_h265.rs27 io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>,
38 io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, in new() argument
H A Drtp_h264.rs29 io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>,
38 io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, in new() argument
/xiu/protocol/rtsp/src/
H A Drtsp_track.rs14 fn create_packer(&mut self, writer: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>); in create_packer() argument
61 pub async fn rtp_receive_loop(&mut self, mut rtp_io: Box<dyn TNetIO + Send + Sync>) { in rtp_receive_loop() argument
83 pub async fn rtcp_receive_loop(&mut self, rtcp_io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>) { in rtcp_receive_loop() argument
124 io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, in on_rtcp() argument
129 pub async fn create_packer(&mut self, io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>) { in create_packer() argument
H A Drtsp_channel.rs38 fn create_packer(&mut self, writer: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>); in create_packer() argument
129 fn create_packer(&mut self, io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>) { in create_packer() argument
170 rtcp_io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, in on_rtcp() argument
195 rtcp_io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, in send_rr() argument
/xiu/protocol/rtmp/src/handshake/
H A Dhandshake_server.rs35 pub fn new(io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>) -> Self { in new()
87 pub fn new(io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>) -> Self { in new()
278 pub fn new(io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>) -> Self { in new()
H A Dhandshake_client.rs25 pub fn new(io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>) -> Self { in new()
/xiu/protocol/webrtc/src/
H A Dwhep.rs89 .add_track(Arc::clone(&video_track) as Arc<dyn TrackLocal + Send + Sync>) in handle_whep()
93 .add_track(Arc::clone(&audio_track) as Arc<dyn TrackLocal + Send + Sync>) in handle_whep()
/xiu/protocol/httpflv/src/
H A Dserver.rs13 type GenericError = Box<dyn std::error::Error + Send + Sync>;
/xiu/protocol/hls/src/
H A Dserver.rs10 type GenericError = Box<dyn std::error::Error + Send + Sync>;
/xiu/protocol/rtsp/src/session/
H A Dmod.rs63 io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>,
113 let net_io: Box<dyn TNetIO + Send + Sync> = Box::new(TcpIO::new(stream)); in new()
363 let box_udp_io: Box<dyn TNetIO + Send + Sync> = Box::new(rtp_io); in handle_setup()
377 let box_rtcp_io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>> = in handle_setup()
428 move |io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, packet: RtpPacket| { in handle_play()
444 move |io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, packet: RtpPacket| { in handle_play()
/xiu/library/bytesio/src/
H A Dbytes_writer.rs156 pub io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>,
160 pub fn new(io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>) -> Self { in new()
H A Dbytesio.rs23 pub trait TNetIO: Send + Sync {
/xiu/protocol/rtmp/src/chunk/
H A Dpacketizer.rs31 pub fn new(io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>) -> Self { in new()
/xiu/protocol/rtmp/src/netstream/
H A Dwriter.rs20 pub fn new(io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>) -> Self { in new()
/xiu/protocol/webrtc/src/session/
H A Dmod.rs39 io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>,
53 let net_io: Box<dyn TNetIO + Send + Sync> = Box::new(TcpIO::new(stream)); in new()
/xiu/protocol/rtmp/src/session/
H A Dclient_session.rs71 io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>,
110 let tcp_io: Box<dyn TNetIO + Send + Sync> = Box::new(TcpIO::new(stream)); in new()
H A Dserver_session.rs53 io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>,
78 let tcp_io: Box<dyn TNetIO + Send + Sync> = Box::new(TcpIO::new(stream)); in new()
/xiu/library/streamhub/src/
H A Ddefine.rs175 pub trait TStreamHandler: Send + Sync {
/xiu/protocol/rtmp/src/netconnection/
H A Dwriter.rs70 pub fn new(io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>) -> Self { in new()