Skip to main content

start_outgoing_packet_pipeline

hopr_transport_protocol::pipeline

Function start_outgoing_packet_pipeline 

Source 
async fn start_outgoing_packet_pipeline<AppOut, E, WOut, WOutErr>(
    app_outgoing: AppOut,
    encoder: Arc<E>,
    wire_outgoing: WOut,
    counters: PeerProtocolCounterRegistry,
    concurrency: usize,
)
where
    AppOut: Stream<Item = (ResolvedTransportRouting<HoprSurb>, ApplicationDataOut)> + Send + 'static,
    E: PacketEncoder + Send + Sync + 'static,
    WOut: Sink<(PeerId, Box<[u8]>), Error = SinkTimeoutError<WOutErr>> + Clone + Unpin + Send + 'static,
    WOutErr: Error,
Expand description

Performs encoding of outgoing Application protocol packets into HOPR protocol outgoing packets.