Skip to main content

start_outgoing_packet_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.