Lines Matching refs:new

35     pub fn new(io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>) -> Self {  in new()  method
37 reader: BytesReader::new(BytesMut::new()), in new()
38 writer: AsyncBytesWriter::new(io), in new()
41 c1_bytes: BytesMut::new(), in new()
87 pub fn new(io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>) -> Self { in new() method
89 reader: BytesReader::new(BytesMut::new()), in new()
90 writer: AsyncBytesWriter::new(io), in new()
93 c1_digest: BytesMut::new(), in new()
150 let mut reader = BytesReader::new(c1_bytes); in read_c1()
194 self.c1_timestamp = BytesReader::new(c1_bytes.clone()).read_u32::<BigEndian>()?; in read_c1()
197 let mut key = BytesMut::new(); in read_c1()
200 let mut digest_processor = DigestProcessor::new(c1_bytes, key); in read_c1()
220 let mut writer = BytesWriter::new(); in write_s1()
227 let mut key = BytesMut::new(); in write_s1()
230 let mut digest_processor = DigestProcessor::new(writer.extract_current_bytes(), key); in write_s1()
240 let mut writer = BytesWriter::new(); in write_s2()
247 let mut key = BytesMut::new(); in write_s2()
250 let mut digest_processor = DigestProcessor::new(BytesMut::new(), key); in write_s2()
254 let mut data: BytesMut = BytesMut::new(); in write_s2()
257 let mut digest_processor_2 = DigestProcessor::new(BytesMut::new(), tmp_key); in write_s2()
278 pub fn new(io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>) -> Self { in new() method
280 simple_handshaker: SimpleHandshakeServer::new(io.clone()), in new()
281 complex_handshaker: ComplexHandshakeServer::new(io), in new()
284 saved_data: BytesMut::new(), in new()