Home
last modified time | relevance | path

Searched refs:handshake (Results 1 – 7 of 7) sorted by relevance

/xiu/protocol/rtmp/src/handshake/
H A Dhandshake_server.rs49 pub async fn handshake(&mut self) -> Result<(), HandshakeError> { in handshake() method
102 pub async fn handshake(&mut self) -> Result<(), HandshakeError> { in handshake() method
311 pub async fn handshake(&mut self) -> Result<(), HandshakeError> { in handshake() method
314 let result = self.complex_handshaker.handshake().await; in handshake()
324 self.simple_handshaker.handshake().await?; in handshake()
329 self.simple_handshaker.handshake().await?; in handshake()
H A Dhandshake_client.rs42 pub async fn handshake(&mut self) -> Result<(), HandshakeError> { in handshake() method
/xiu/protocol/rtmp/src/
H A Dlib.rs16 pub mod handshake; module
/xiu/protocol/rtmp/src/session/
H A Dclient_session.rs16 handshake,
17 handshake::{define::ClientHandshakeState, handshake_client::SimpleHandshakeClient},
150 self.handshake().await?; in run()
210 async fn handshake(&mut self) -> Result<(), SessionError> { in handshake() method
212 self.handshaker.handshake().await?; in handshake()
219 while bytes_len < handshake::define::RTMP_HANDSHAKE_SIZE * 2 { in handshake()
H A Dserver_session.rs16 config, handshake,
17 handshake::{define::ServerHandshakeState, handshake_server::HandshakeServer},
107 self.handshake().await?; in run()
124 async fn handshake(&mut self) -> Result<(), SessionError> { in handshake() method
127 while bytes_len < handshake::define::RTMP_HANDSHAKE_SIZE { in handshake()
133 self.handshaker.handshake().await?; in handshake()
H A Derrors.rs6 handshake::errors::HandshakeError,
/xiu/protocol/rtmp/
H A DREADME.md130 - Support complex handshake
142 - Refactor handshake mod;
148 - Fix handshake error.[#23]