Struct libp2p_swarm::SwarmBuilder

pub struct SwarmBuilder<TBehaviour, TConnInfo> { /* fields omitted */ }

Methods

impl<TBehaviour, TConnInfo> SwarmBuilder<TBehaviour, TConnInfo> where
    TBehaviour: NetworkBehaviour,
    TConnInfo: ConnectionInfo<PeerId = PeerId> + Debug + Clone + Send + 'static, 

pub fn new<TTransport, TMuxer>(
    transport: TTransport,
    behaviour: TBehaviour,
    local_peer_id: PeerId
) -> Self where
    TMuxer: StreamMuxer + Send + Sync + 'static,
    TMuxer::OutboundSubstream: Send + 'static,
    <TMuxer as StreamMuxer>::OutboundSubstream: Send + 'static,
    <TMuxer as StreamMuxer>::Substream: Send + 'static,
    TTransport: Transport<Output = (TConnInfo, TMuxer)> + Clone + Send + Sync + 'static,
    TTransport::Error: Send + Sync + 'static,
    TTransport::Listener: Send + 'static,
    TTransport::ListenerUpgrade: Send + 'static,
    TTransport::Dial: Send + 'static, 

pub fn incoming_limit(self, incoming_limit: Option<u32>) -> Self

pub fn executor(self, executor: impl Executor + Send + 'static) -> Self

Sets the executor to use to spawn background tasks.

By default, uses a threads pool.

pub fn executor_fn(
    self,
    executor: impl Fn(Pin<Box<dyn Future<Output = ()> + Send>>) + Send + 'static
) -> Self

Shortcut for calling executor with an object that calls the given closure.

pub fn build(self) -> Swarm<TBehaviour, TConnInfo>