utils.py 文件源码

def run_producers_test(producers, names, args):
    loop = GLib.MainLoop()

    [producer.start() for producer in producers]
    producer.start()


    if args.output:
        from ..file import FileConsumer
        consumers = [FileConsumer(n, filename="%s-%s"%(args.output, o)) for o,n in enumerate(names)]

        def check_complete(*a):
            if all([c._emitted_complete for c in consumers]):
                print("ALL RETRIEVED")
                loop.quit()

        [consumer.connect('complete', check_complete) for consumer in consumers]
        [consumer.start() for consumer in consumers]
    loop.run()