@gen.coroutine
def assert_read_from_all(
        testcase, rsc, members, mode,
        tag_sets=None, secondary_acceptable_latency_ms=15):
    nsamples = 100
    members = set(members)
    used = set((yield [
        read_from_which_host(
            rsc, mode, tag_sets, secondary_acceptable_latency_ms)
        for _ in range(nsamples)
    ]))

    testcase.assertEqual(members, used)
Begins the OAuth 1.0a authorization process for this service.
dataset/ETHPy150Open mongodb/motor/test/high_availability/test_motor_ha_utils.py/assert_read_from_all--crossover with--dataset/ETHPy150Open joelverhagen/flask-rauth/flask_rauth.py/RauthOAuth1.authorize