Struct Channel

pub struct Channel<T>(/* private fields */);

A channel for passing messages between fibers. This api is backed by the tarantool fiber_channel api which is not awailable in all versions of tarantool. Use tarantool::ffi::has_fiber_channel to check if it is supported in your case. If has_fiber_channel returns false, using any function from this module will result in a panic.

Implementations

impl<T> Channel<T>

pub fn new(size: u32) -> Self

pub fn close(self)

pub fn is_closed(&self) -> bool

pub fn is_empty(&self) -> bool

pub fn size(&self) -> u32

pub fn count(&self) -> u32

pub fn has_readers(&self) -> bool

pub fn has_writers(&self) -> bool

impl<T> Channel<T>

pub unsafe extern "C" fn destroy_msg(msg: *mut ipc_msg)

Safety

msg must have been created with ffi::ipc_value_new

impl<T> Channel<T>

pub fn iter(&self) -> Iter<'_, T>

pub fn try_iter(&self) -> TryIter<'_, T>

impl<T> Channel<T>

pub fn send(&self, t: T) -> Result<(), T>

where T: 'static,

pub fn send_timeout(&self, t: T, timeout: Duration) -> Result<(), SendError<T>>

where T: 'static,

pub fn try_send(&self, t: T) -> Result<(), TrySendError<T>>

where T: 'static,

pub fn recv(&self) -> Option<T>

pub fn recv_timeout(&self, timeout: Duration) -> Result<T, RecvError>

pub fn try_recv(&self) -> Result<T, TryRecvError>

Trait Implementations

impl<T> Clone for Channel<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> Debug for Channel<T>

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

Formats the value using the given formatter.

impl<'a, T> IntoIterator for &'a Channel<T>

type Item = T

The type of the elements being iterated over.

type IntoIter = Iter<'a, T>

Which kind of iterator are we turning this into?

fn into_iter(self) -> Iter<'a, T>

Creates an iterator from a value.

impl<T> IntoIterator for Channel<T>

type Item = T

The type of the elements being iterated over.

type IntoIter = IntoIter<T>

Which kind of iterator are we turning this into?

fn into_iter(self) -> IntoIter<T>

Creates an iterator from a value.

impl<T> RecvTimeout<T> for Channel<T>

fn recv_maybe_timeout(&self, timeout: Option<Duration>) -> Result<T, RecvError>

Receive a message from the channel.

fn recv(&self) -> Option<T>

fn recv_timeout(&self, timeout: Duration) -> Result<T, RecvError>

fn try_recv(&self) -> Result<T, TryRecvError>

impl<T> SendTimeout<T> for Channel<T>

fn send_maybe_timeout( &self, t: T, timeout: Option<Duration>, ) -> Result<(), SendError<T>>

where T: 'static,

Send a message t over the channel.

fn send(&self, t: T) -> Result<(), T>

where T: 'static,

fn send_timeout(&self, t: T, timeout: Duration) -> Result<(), SendError<T>>

where T: 'static,

fn try_send(&self, t: T) -> Result<(), TrySendError<T>>

where T: 'static,