def iterateLineGenerator(proto, gen):
 coll = _IteratorBuffer(proto.transport.writeSequence, gen)
 return proto.schedule(coll)

def iterateLineGenerator ( proto , gen ) : coll = _IteratorBuffer ( proto . transport . writeSequence , gen ) return proto . schedule ( coll )
hook the given protocol instance up to the given iterator with an _iteratorbuffer and schedule the result to be exhausted via the protocol .