pub struct TcpAllocator<A>
where A: Allocate,
{ /* private fields */ }
Expand description

A TCP-based allocator for inter-process communication.

Trait Implementations§

source§

impl<A> Allocate for TcpAllocator<A>
where A: Allocate,

source§

fn index(&self) -> usize

The index of the worker out of (0..self.peers()).
source§

fn peers(&self) -> usize

The number of workers in the communication group.
source§

fn allocate<T>( &mut self, identifier: usize, ) -> (Vec<Box<dyn Push<T>>>, Box<dyn Pull<T>>)
where T: Exchangeable,

Constructs several send endpoints and one receive endpoint.
source§

fn receive(&mut self)

Ensure that received messages are surfaced in each channel. Read more
source§

fn release(&mut self)

Signal the completion of a batch of reads from channels. Read more
source§

fn events(&self) -> &Rc<RefCell<Vec<usize>>>

A shared queue of communication events with channel identifier. Read more
source§

fn await_events(&self, duration: Option<Duration>)

Awaits communication events. Read more
source§

fn pipeline<T>( &mut self, identifier: usize, ) -> (Pusher<T, Pusher<T>>, Puller<T, Puller<T>>)
where T: 'static,

Constructs a pipeline channel from the worker to itself. Read more

Auto Trait Implementations§

§

impl<A> Freeze for TcpAllocator<A>
where A: Freeze,

§

impl<A> !RefUnwindSafe for TcpAllocator<A>

§

impl<A> !Send for TcpAllocator<A>

§

impl<A> !Sync for TcpAllocator<A>

§

impl<A> Unpin for TcpAllocator<A>
where A: Unpin,

§

impl<A> !UnwindSafe for TcpAllocator<A>

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>,

§

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>,

§

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.