pub async fn serf_get_queue_max<T>( transport_opts: T::Options, get_addr: impl FnMut(usize) -> T::ResolvedAddress, )where T: Transport<Id = SmolStr>, T::Options: Clone,
test
Unit tests for the get queue max