Python3 txtorcon Event Stream

import txtorcon
from twisted.internet import defer, task


async def main(reactor):
    tor = await txtorcon.connect(reactor)
    print("tor {}".format(tor))

    state = await tor.create_state()
    print("state {}".format(state))

    print("waiting for new stream events:")
    async for name, args, kw in state.stream_events('new'):
        stream = args[0]
        print("{}: {}".format(name, stream))

@task.react
def _main(reactor):
    d = defer.ensureDeferred(main(reactor))                                                                                   
    return d