Struct aqueue::RwModel

pub struct RwModel<I> { /* private fields */ }

RwModel Ensure Thread safety and high performance reading and writing

Implementations

impl<I: 'static> RwModel<I>

pub fn new(x: I) -> RwModel<I>

pub async fn call_mut<'a, T, R>( &'a self, call: impl FnOnce(&'a mut I) -> T ) -> Rwhere T: Future<Output = R>,

Behavior through queues,thread safe call async fn write ref mut

pub async fn call<'a, T, R>(&'a self, call: impl FnOnce(&'a I) -> T) -> Rwhere T: Future<Output = R>,

Behavior through queues,thread safe call async fn read ref

pub fn sync_call<R>(&self, call: impl FnOnce(&I) -> R) -> R

Thread safe call async fn read, Balanced queues are not supported

pub fn sync_mut_call<R>(&self, call: impl FnOnce(&mut I) -> R) -> R

Thread safe call async fn write, Balanced queues are not supported

Trait Implementations

impl<I: Default> Default for RwModel<I>

fn default() -> Self

Returns the “default value” for a type.