def source(target, inputstream=sys.stdin):
for line in inputstream:<EOL><INDENT>while len(line) > <NUM_LIT>:<EOL><INDENT>init, sep, line = line.partition('<STR_LIT:U+0020>')<EOL>assert len(init) <= <NUM_LIT><EOL>target.send('<STR_LIT>'.join([init, sep]))<EOL><DEDENT>target.send(line)<EOL><DEDENT>inputstream.close()<EOL>return target.close()<EOL>
Coroutine starting point. Produces text stream and forwards to consumers

:param target: Target coroutine consumer
:type target: Coroutine

:param inputstream: Input Source
:type inputstream: BufferedTextIO Object