Struct timely::communication::allocator::zero_copy::allocator::TcpBuilder

pub struct TcpBuilder<A>
where
    A: AllocateBuilder,
{ /* private fields */ }

Builds an instance of a TcpAllocator.

Builders are required because some of the state in a TcpAllocator cannot be sent between threads (specifically, the Rc<RefCell<_>> local channels). So, we must package up the state shared between threads here, and then provide a method that will instantiate the non-movable members once in the destination thread.

Implementations

impl<A> TcpBuilder<A>

where A: AllocateBuilder,

pub fn build(self) -> TcpAllocator<<A as AllocateBuilder>::Allocator>

Builds a TcpAllocator, instantiating Rc<RefCell<_>> elements.