Struct GenericCallback

pub struct GenericCallback<T>(GenericCallbackVariants<T>)
where
    T: Serialize + Send + 'static;

A mechanism to run a callback in the process this callback was constructed in.

The GenericCallback can be sent cross-process (in multi-process mode). In this case the callback will be executed on the ROUTER thread. In single-process mode the callback will be executed directly.

Tuple Fields

0: GenericCallbackVariants<T>

Implementations

impl<T> GenericCallback<T>

where T: for<'de> Deserialize<'de> + Serialize + Send + 'static,

pub fn new<F: FnMut(Result<T, Error>) + Send + 'static>( callback: F, ) -> Result<Self, Error>

Creates a new GenericCallback.

The callback should not do any heavy work and not block.

pub fn send(&self, value: T) -> SendResult

Send value to the callback.

Note that a return value of Ok() simply means that value was sent successfully to the callback. The callback itself does not return any value. The caller may not assume that the callback is executed synchronously.

Trait Implementations

impl<T> Clone for GenericCallback<T>

where T: Serialize + Send + 'static,

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T> Debug for GenericCallback<T>

where T: Serialize + Send + 'static,

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

Formats the value using the given formatter.

impl<'a, T> Deserialize<'a> for GenericCallback<T>

where T: Serialize + Deserialize<'a> + Send + 'static,

fn deserialize<D>(d: D) -> Result<GenericCallback<T>, D::Error>

where D: Deserializer<'a>,

Deserialize this value from the given Serde deserializer.

impl<T> MallocSizeOf for GenericCallback<T>

where T: Serialize + Send + 'static,

fn size_of(&self, _ops: &mut MallocSizeOfOps) -> usize

Measure the heap usage of all descendant heap-allocated structures, but not the space taken up by the value itself.

impl<T> Serialize for GenericCallback<T>

where T: Serialize + Send + 'static,

fn serialize<S: Serializer>(&self, s: S) -> Result<S::Ok, S::Error>

Serialize this value into the given Serde serializer.