Lines Matching refs:num_messages
312 num_messages: usize, field
465 assert!(state.num_messages < MAX_CAPACITY, "buffer space \ in inc_num_messages()
468 state.num_messages += 1; in inc_num_messages()
473 return Some(state.num_messages) in inc_num_messages()
549 Some(num_messages) => { in do_send_b()
552 num_messages > self.inner.buffer in do_send_b()
603 assert!(state.num_messages < MAX_CAPACITY, "buffer space \ in inc_num_messages()
606 state.num_messages += 1; in inc_num_messages()
611 return Some(state.num_messages) in inc_num_messages()
1331 !self.is_open && self.num_messages == 0 in is_closed()
1344 num_messages: num & MAX_CAPACITY, in decode_state()
1349 let mut num = state.num_messages; in encode_state()