Struct network::peer::Peer

pub struct Peer<TSocket> { /* fields omitted */ }

The Peer actor manages a single connection to another remote peer after the initial connection establishment and handshake.

Implementations

impl<TSocket> Peer<TSocket> where
    TSocket: AsyncRead + AsyncWrite + Send + 'static, 

pub fn new(
    network_context: NetworkContext,
    executor: Handle,
    time_service: TimeService,
    connection: Connection<TSocket>,
    connection_notifs_tx: Sender<TransportNotification<TSocket>>,
    peer_reqs_rx: Receiver<ProtocolId, PeerRequest>,
    peer_notifs_tx: Sender<ProtocolId, PeerNotification>,
    inbound_rpc_timeout: Duration,
    max_concurrent_inbound_rpcs: u32,
    max_concurrent_outbound_rpcs: u32,
    max_frame_size: usize,
    inbound_rate_limiter: Option<SharedBucket>,
    outbound_rate_limiter: Option<SharedBucket>
) -> Self

pub async fn start(self)