Struct Config

pub struct Config { /* private fields */ }

Configuration for the multiplexer.

Implementations

impl Config

pub fn new() -> Config

Builds the default configuration.

pub fn set_max_num_streams(&mut self, max: usize) -> &mut Self

Sets the maximum number of simultaneously used substreams.

A substream is used as long as it has not been dropped, even if it may already be closed or reset at the protocol level (in which case it may still have buffered data that can be read before the StreamMuxer API signals EOF).

When the limit is reached, opening of outbound substreams is delayed until another substream is dropped, whereas new inbound substreams are immediately answered with a Reset. If the number of inbound substreams that need to be reset accumulates too quickly (judged by internal bounds), the connection is closed with an error due to the misbehaved remote.

pub fn set_max_buffer_size(&mut self, max: usize) -> &mut Self

Sets the maximum number of frames buffered per substream.

A limit is necessary in order to avoid DoS attacks.

pub fn set_max_buffer_behaviour( &mut self, behaviour: MaxBufferBehaviour, ) -> &mut Self

Sets the behaviour when the maximum buffer size is reached for a substream.

See the documentation of MaxBufferBehaviour.

pub fn set_split_send_size(&mut self, size: usize) -> &mut Self

Sets the frame size used when sending data. Capped at 1Mbyte as per the Mplex spec.

pub fn set_protocol_name(&mut self, protocol_name: &'static str) -> &mut Self

Set the protocol name.

use libp2p_mplex::MplexConfig;
let mut muxer_config = MplexConfig::new();
muxer_config.set_protocol_name("/mplex/6.7.0");

Trait Implementations

impl Clone for Config

fn clone(&self) -> Config

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Config

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

Formats the value using the given formatter.

impl Default for Config

fn default() -> Config

Returns the “default value” for a type.

impl<C> InboundConnectionUpgrade<C> for Config

where C: AsyncRead + AsyncWrite + Unpin,

type Output = Multiplex<C>

Output after the upgrade has been successfully negotiated and the handshake performed.

type Error = Error

Possible error during the handshake.

type Future = Ready<Result<<Config as InboundConnectionUpgrade<C>>::Output, Error>>

Future that performs the handshake with the remote.

fn upgrade_inbound(self, socket: C, _: Self::Info) -> Self::Future

After we have determined that the remote supports one of the protocols we support, this method is called to start the handshake.

impl<C> OutboundConnectionUpgrade<C> for Config

where C: AsyncRead + AsyncWrite + Unpin,

type Output = Multiplex<C>

Output after the upgrade has been successfully negotiated and the handshake performed.

type Error = Error

Possible error during the handshake.

type Future = Ready<Result<<Config as OutboundConnectionUpgrade<C>>::Output, Error>>

Future that performs the handshake with the remote.

fn upgrade_outbound(self, socket: C, _: Self::Info) -> Self::Future

After we have determined that the remote supports one of the protocols we support, this method is called to start the handshake.

impl UpgradeInfo for Config

type Info = &'static str

Opaque type representing a negotiable protocol.

type InfoIter = Once<<Config as UpgradeInfo>::Info>

Iterator returned by protocol_info.

fn protocol_info(&self) -> Self::InfoIter

Returns the list of protocols that are supported. Used during the negotiation process.