Struct Listener

pub struct Listener {
    key_pair: KeyPair,
    task_group: TaskGroup,
    connection_slots: Arc<ConnectionSlots>,
    enable_tls: bool,
    monitor: Arc<Monitor>,
}

Responsible for creating inbound connections with other peers.

Fields

key_pair: KeyPair

Identity Key pair

task_group: TaskGroup

Managing spawned tasks.

connection_slots: Arc<ConnectionSlots>

Manages available inbound slots.

enable_tls: bool

Enables secure connection.

monitor: Arc<Monitor>

Responsible for network and system monitoring.

Implementations

impl Listener

pub fn new( key_pair: &KeyPair, connection_slots: Arc<ConnectionSlots>, enable_tls: bool, monitor: Arc<Monitor>, ex: Executor, ) -> Arc<Self>

Creates a new Listener

pub async fn start<Fut>( self: &Arc<Self>, endpoint: Endpoint, callback: impl FnOnce(Conn<NetMsg, Error>) -> Fut + Clone + Send + 'static, ) -> Result<Endpoint>

where Fut: Future<Output = Result<()>> + Send + 'static,

Starts a listener on the given endpoint. For each incoming connection that is accepted, it invokes the provided callback, and pass the connection to the callback.

Returns the resloved listening endpoint.

pub async fn shutdown(&self)

Shuts down the listener

async fn listen_loop<Fut>( self: Arc<Self>, listener: Listener<NetMsg, Error>, callback: impl FnOnce(Conn<NetMsg, Error>) -> Fut + Clone + Send + 'static, )

where Fut: Future<Output = Result<()>> + Send + 'static,

async fn listen(&self, endpoint: &Endpoint) -> Result<Listener<NetMsg, Error>>