seq_watcher

Struct SequenceWatchers

Source
pub struct SequenceWatchers<T>
where T: Eq + Clone + Debug + Hash,
{ /* private fields */ }
Expand description

Monitors a stream of data for multiple sequences of data items.

§Examples

use seq_watcher::SequenceWatchers;

const CTRL_C: u8 = 3;
const CTRL_D: u8 = 4;

// Watch the input stream for two consecutive <CTRL-C> characters.
let watchers = SequenceWatchers::new(&[&[CTRL_C, CTRL_C], &[CTRL_C, CTRL_D]]);

for b in b'a'..=b'z' {
    assert_eq!(false, watchers.check(&b));   // Send single ASCII byte
    assert_eq!(false, watchers.check(&CTRL_C));   // Send single <Ctrl-C>
}
assert_eq!(true, watchers.check(&CTRL_C));    // Send a second <Ctrl-C>
assert_eq!(true, watchers.check(&CTRL_D));    // Send a <Ctrl-D>

Implementations§

Source§

impl<T: Eq + Clone + Debug + Hash> SequenceWatchers<T>

Source

pub fn new(sequences: &[&[T]]) -> Self

Create a new SequenceWatchers from a slice of slices of data. The data type can be anything with Eq, Debug, and Clone traits.

Internally, the SequenceWatchers structure contains a vector of SequenceWatcher structures.

§Examples
let watchers = SequenceWatchers::new(&[&['q'], &['Q']]);

assert_eq!(true, watchers.check(&'q'));
assert_eq!(true, watchers.check(&'Q'));
Source

pub fn check(&self, value: &T) -> bool

Tells the SequenceWatchers of a new input item and checks to see if a sequence has been completed. Returns true when a sequence is completed.

§Examples
let watchers = SequenceWatchers::new(&[&[false, true], &[false, true, true]]);

assert_eq!(false, watchers.check(&true));
assert_eq!(false, watchers.check(&false));
assert_eq!(true, watchers.check(&true));    // Matches first sequence
assert_eq!(true, watchers.check(&true));    // Matches second sequence
Source

pub fn add(&mut self, new_seq: &[T])

Adds a new SequenceWatcher to the SequenceWatchers. If the sequence matches a pre-existing SequenceWatcher, it does nothing.

§Examples
let mut watchers = SequenceWatchers::new(&[]);
watchers.add(&[]);  // This does nothing.
watchers.add(&[false, true]);
watchers.add(&[false, true, true]);

assert_eq!(false, watchers.check(&true));
assert_eq!(false, watchers.check(&false));
assert_eq!(true, watchers.check(&true));    // Matches first sequence
assert_eq!(true, watchers.check(&true));    // Matches second sequence
Source

pub fn remove(&mut self, seq: &[T]) -> Option<SequenceWatcher<T>>

Removes a sequence watcher for a given sequence. It returns the removed SequenceWatcher.

§Examples
let mut watchers = SequenceWatchers::new(&[&[false, true], &[false, true, true]]);
watchers.remove(&[false, true, true]);

assert_eq!(false, watchers.check(&true));
assert_eq!(false, watchers.check(&false));
assert_eq!(true, watchers.check(&true));    // Matches first sequence
assert_eq!(false, watchers.check(&true));   // Matches second sequence, which was removed
Source

pub fn len(&self) -> usize

Returns the number of sequences being monitored.

§Examples
let watchers = SequenceWatchers::new(&[&['A'], &['B'], &['C'], &['D']]);

assert_eq!(4, watchers.len());
Source

pub fn sequences(&self) -> Keys<'_, Vec<T>, SequenceWatcher<T>>

Returns an iterator over the sequences being monitored by the SequenceWatchers.

§Examples
let watchers = SequenceWatchers::new(&[&[false, true], &[false, true, true]]);

let mut sequences: Vec<&Vec<bool>> = watchers.sequences().collect();
sequences.sort();   // Make sure keys are sorted.
let mut sequences = sequences.into_iter();
assert_eq!(sequences.next(), Some(&vec![false, true]));
assert_eq!(sequences.next(), Some(&vec![false, true, true]));
assert_eq!(sequences.next(), None);

Trait Implementations§

Source§

impl<T> Debug for SequenceWatchers<T>
where T: Eq + Clone + Debug + Hash + Debug,

Source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more

Auto Trait Implementations§

§

impl<T> Freeze for SequenceWatchers<T>

§

impl<T> !RefUnwindSafe for SequenceWatchers<T>

§

impl<T> Send for SequenceWatchers<T>
where T: Send,

§

impl<T> !Sync for SequenceWatchers<T>

§

impl<T> Unpin for SequenceWatchers<T>
where T: Unpin,

§

impl<T> UnwindSafe for SequenceWatchers<T>
where T: UnwindSafe,

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.