Searched refs:next_sequence_nr (Results 1 – 2 of 2) sorted by relevance
5 next_sequence_nr: Arc<AtomicU32>, field12 next_sequence_nr: Arc<AtomicU32>, in new()17 next_sequence_nr, in new()28 let sequence_number = self.next_sequence_nr.fetch_add(1, Ordering::SeqCst); in write()
36 next_sequence_nr: Arc::new(AtomicU32::new(self.init_sequence_nr)), in build()44 next_sequence_nr: Arc<AtomicU32>, field96 Arc::clone(&self.next_sequence_nr), in bind_local_stream()