Struct ConditionVariable

pub struct ConditionVariable<T> { /* private fields */ }

Implementations

impl<T: PartialEq + Clone> ConditionVariable<T>

pub fn new(value: T) -> ConditionVariable<T>

pub fn set(&self, value: T, notify: Notify)

pub fn touch(&self, notify: Notify)

pub fn get(&self) -> Result<T, PoisonError<MutexGuard<'_, T>>>

pub fn wait_for( &self, expected: T, ) -> Result<(), PoisonError<MutexGuard<'_, T>>>

pub fn wait_for_in( &self, expected: &[T], ) -> Result<(), PoisonError<MutexGuard<'_, T>>>

pub fn wait_for_update(&self) -> Result<(), PoisonError<MutexGuard<'_, T>>>

pub fn wait_for_condition<F: FnMut(&T) -> bool>( &self, cond_func: F, ) -> Result<(), PoisonError<MutexGuard<'_, T>>>

pub fn wait_for_ms( &self, expected: T, timeout_ms: i64, ) -> Result<bool, PoisonError<(MutexGuard<'_, T>, bool)>>

pub fn wait_for_in_ms( &self, expected: &[T], timeout_ms: i64, ) -> Result<bool, PoisonError<(MutexGuard<'_, T>, bool)>>

pub fn wait_for_update_ms( &self, timeout_ms: i64, ) -> Result<bool, PoisonError<(MutexGuard<'_, T>, bool)>>

pub fn wait_for_condition_ms<F: FnMut(&T) -> bool>( &self, cond_func: F, timeout_ms: i64, ) -> Result<bool, PoisonError<(MutexGuard<'_, T>, bool)>>

impl<T: PartialEq + Clone + Send> ConditionVariable<T>

pub fn as_channel_once(&self) -> Receiver<T>

Sends out a value over the channel as soon as the ConditionVariable changes its value

impl ConditionVariable<()>

pub fn wait_ms(&self, timeout_ms: u32) -> LockResult<(MutexGuard<'_, ()>, bool)>

waits for a notify (useful if T==())