Function topolotree::run_topolotree
source ยท pub(crate) fn run_topolotree(
neighbors: Vec<u32>,
input_recv: impl Stream<Item = Result<(u32, BytesMut), Error>> + Unpin + 'static,
increment_requests: impl Stream<Item = Result<BytesMut, Error>> + Unpin + 'static,
output_send: UnboundedSender<(u32, Bytes)>,
query_send: UnboundedSender<Bytes>,
) -> Dfir<'static>