async fn run_tally<T, S>( rx: UnboundedReceiver<S::Vote>, tally: S, ) -> Option<S::Output>where T: NodeType, S: Tally<T>,