Searched refs:in_queue (Results 1 – 1 of 1) sorted by relevance
1096 in_queue: VecDeque<Vec<u8>>, field1102 Self { in_queue: VecDeque::new(), out_queue: VecDeque::new() } in new()1106 self.in_queue.push_back(packet.into()); in add_input()1112 match self.in_queue.pop_front() { in receive_packet()1131 in_queue: VecDeque<u8>, field1138 data.iter().for_each(|v| self.in_queue.push_back(*v)); in add_input()1151 *ele = self.in_queue.pop_front().ok_or(TransportError::Others("No more data"))?; in read_exact()