Function topolotree::run_topolotree

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>