Previous topic

cogen.core.events

Next topic

cogen.core.proactors

This Page

Quick search

Enter search terms or a module, class or function name.

cogen.core.pipe

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)
class cogen.core.pipe.Iterate(coro, args=(), kwargs={}, sentinel=<cogen.core.pipe.chunk_sentinel object at 0x030B8750>)

Bases: cogen.core.events.Operation

finalize()
process(sched, coro)
class cogen.core.pipe.IterateToken(iterator)

Bases: cogen.core.events.Operation

finalize()
process(sched, coro)
stop()
class cogen.core.pipe.IteratedCoroutineInstance(coro, *args, **kws)

Bases: cogen.core.coroutines.CoroutineInstance

iter_token
run_op(op)
exception cogen.core.pipe.IterationStopped
Bases: exceptions.Exception
class cogen.core.pipe.chunk(data)

Bases: object

value
class cogen.core.pipe.chunk_sentinel
Bases: object