Skip to main content

run_hopr_packet_pipeline

hopr_transport::pipeline

Function run_hopr_packet_pipeline 

Source 
pub fn run_hopr_packet_pipeline<WIn, WOut, Chain, S, TEvt, TFact, AppOut, AppIn>(
    (packet_key, chain_key): (OffchainKeypair, ChainKeypair),
    wire_msg: (WOut, WIn),
    api: (AppOut, AppIn),
    components: HoprPipelineComponents<TEvt, S, Chain, TFact>,
    channels_dst: Hash,
    cfg: HoprPacketPipelineConfig,
) -> AbortableList<HoprTransportProcess>
where
    WOut: Sink<(PeerId, Box<[u8]>)> + Clone + Unpin + Send + 'static,
    WOut::Error: Error,
    WIn: Stream<Item = (PeerId, Box<[u8]>)> + Send + 'static,
    Chain: ChainKeyOperations + ChainReadChannelOperations + ChainReadTicketOperations + ChainValues + Clone + Send + Sync + 'static,
    S: SurbStore + Clone + Send + Sync + 'static,
    TEvt: Sink<TicketEvent> + Clone + Unpin + Send + 'static,
    TEvt::Error: Error,
    TFact: TicketFactory + Clone + Send + Sync + 'static,
    AppOut: Sink<(HoprPseudonym, ApplicationDataIn)> + Send + 'static,
    AppOut::Error: Error,
    AppIn: Stream<Item = (ResolvedTransportRouting<HoprSurb>, ApplicationDataOut)> + Send + 'static,