Function network_clique::protocols::v1::incoming

source ·

pub async fn incoming<SK: SecretKey, D: Data, S: Splittable>(
    stream: S,
    secret_key: SK,
    authorization_requests_sender: UnboundedSender<(SK::PublicKey, Sender<bool>)>,
    result_for_parent: UnboundedSender<(SK::PublicKey, Option<UnboundedSender<D>>)>,
    data_for_user: UnboundedSender<D>,
    metrics: Metrics
) -> Result<(), ProtocolError<SK::PublicKey>>

Expand description

Performs the incoming handshake, and then manages a connection sending and receiving data. Exits on parent request (when the data source is dropped), or in case of broken or dead network connection.