Skip to main content

start_relay_incoming_ack_pipeline

hopr_transport::protocol::pipeline

Function start_relay_incoming_ack_pipeline 

Source 
async fn start_relay_incoming_ack_pipeline<AckIn, T, TEvt>(
    ack_incoming: AckIn,
    ticket_events: TEvt,
    ticket_proc: Arc<T>,
    concurrency: usize,
)
where
    AckIn: Stream<Item = (OffchainPublicKey, Vec<Acknowledgement>)> + Send + 'static,
    T: UnacknowledgedTicketProcessor + Sync + Send + 'static,
    TEvt: Sink<TicketEvent> + Clone + Unpin + Send + 'static,
    TEvt::Error: Error,