Struct fibers_transport::TcpTransporterBuilder

pub struct TcpTransporterBuilder<E, D> { /* fields omitted */ }

TcpTransporter builder.

Implementations

impl<E, D> TcpTransporterBuilder<E, D> where
    E: Encode + Default,
    D: Decode + Default, 

pub fn new() -> Self

Makes a new TcpTransporterBuilder with the default settings.

impl<E: Encode, D: Decode> TcpTransporterBuilder<E, D>

pub fn with_codec(encoder: E, decoder: D) -> Self

Makes a new TcpTransporterBuilder with the given encoder and decoder.

pub fn buf_size(self, size: usize) -> Self

Sets the application level read/write buffer size of the resulting instance in byte.

The default value is 8192.

pub fn finish(self, stream: TcpStream) -> Result<TcpTransporter<E, D>>

Builds a TcpTransporterBuilder instance from the given TcpStream.

pub fn connect(
    self,
    peer: SocketAddr
) -> impl Future<Item = TcpTransporter<E, D>, Error = Error>

Builds a TcpTransporterBuilder instance by connecting to the specified peer.

Trait Implementations

impl<E: Debug, D: Debug> Debug for TcpTransporterBuilder<E, D>

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

Formats the value using the given formatter.

impl<E, D> Default for TcpTransporterBuilder<E, D> where
    E: Encode + Default,
    D: Decode + Default, 

fn default() -> Self

Returns the "default value" for a type.