An unidirectional pipe.
Your average example:
@coro
def iterator():
iterator = yield Iterate(producer)
while 1:
val = yield iterator
if val is sentinel:
break
# do something with val
@coro
def producer():
for i in xrange(100):
yield chunk(i)
Bases: cogen.core.events.Operation
Bases: cogen.core.events.Operation
Bases: cogen.core.coroutines.CoroutineInstance