Struct timely_communication::allocator::zero_copy::allocator::TcpBuilder

pub struct TcpBuilder<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: AllocateBuilder> TcpBuilder<A>

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

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