anatomy of consumer producer

consumer_producers.py

import itertools

def p1():
    res = None
    for x in itertools.cycle(range(5)):
        yield x
        res = yield
        print(f"x={res}")
        if res == -1:
            print(f"ending term for x={x} res={res}")
            yield None

        
def consumer(*producers):
    producers = [each_producer() for each_producer in producers]
    for item in itertools.cycle(producers):
        print(f"item", item)
        if not item:
            return
        print(next(item))
        int_obj = yield
        if int_obj:
            item.send(int_obj)