diff options
Diffstat (limited to 'examples/source.py')
| -rw-r--r-- | examples/source.py | 13 |
1 files changed, 7 insertions, 6 deletions
diff --git a/examples/source.py b/examples/source.py index 7fd11fb..c3ebd55 100644 --- a/examples/source.py +++ b/examples/source.py @@ -1,10 +1,11 @@ """Test client that connects and sends infinite data.""" +from __future__ import print_function import argparse import sys -from asyncio import * -from asyncio import test_utils +from trollius import * +from trollius import test_utils ARGS = argparse.ArgumentParser(description="TCP data sink example.") @@ -74,18 +75,18 @@ def start(loop, host, port): sslctx = None if args.tls: sslctx = test_utils.dummy_ssl_context() - tr, pr = yield from loop.create_connection(Client, host, port, - ssl=sslctx) + tr, pr = yield From(loop.create_connection(Client, host, port, + ssl=sslctx)) dprint('tr =', tr) dprint('pr =', pr) - yield from pr.waiter + yield From(pr.waiter) def main(): global args args = ARGS.parse_args() if args.iocp: - from asyncio.windows_events import ProactorEventLoop + from trollius.windows_events import ProactorEventLoop loop = ProactorEventLoop() set_event_loop(loop) else: |