def METHOD_NAME():
    received = []
    class TestCollector(cirq.Collector):
        def next_job(self):
            q = cirq.LineQubit(0)
            circuit = cirq.Circuit(cirq.H(q), cirq.measure(q))
            return cirq.CircuitSampleJob(circuit=circuit, repetitions=10, tag='test')
        def on_job_result(self, job, result):
            received.append(job.tag)
    TestCollector().collect(sampler=cirq.Simulator(), max_total_samples=100, concurrency=5)
    assert received == ['test'] * 10