Changed how we are importing the test_utils submodule as suggested

Author: denisra

examples/cacheclt.py

@@ -8,6 +8,7 @@
 import logging
 
 import asyncio
+import asyncio.test_utils
 
 
 ARGS = argparse.ArgumentParser(description='Cache client example.')
@@ -173,7 +174,7 @@ def main():
         loop = asyncio.new_event_loop()
     sslctx = None
     if args.tls:
-        sslctx = asyncio.test_utils.dummy_ssl_context()
+        sslctx = test_utils.dummy_ssl_context()
     cache = CacheClient(args.host, args.port, sslctx=sslctx, loop=loop)
     try:
         loop.run_until_complete(

examples/source.py

@@ -4,6 +4,7 @@
 import sys
 
 import asyncio
+import asyncio.test_utils
 
 
 ARGS = argparse.ArgumentParser(description="TCP data sink example.")
@@ -72,7 +73,7 @@ def connection_lost(self, exc):
 def start(loop, host, port):
     sslctx = None
     if args.tls:
-        sslctx = asyncio.test_utils.dummy_ssl_context()
+        sslctx = test_utils.dummy_ssl_context()
     tr, pr = yield from loop.create_connection(Client, host, port,
                                                ssl=sslctx)
     dprint('tr =', tr)

examples/source1.py

@@ -4,6 +4,7 @@
 import sys
 
 import asyncio
+import asyncio.test_utils
 
 
 ARGS = argparse.ArgumentParser(description="TCP data sink example.")
@@ -56,7 +57,7 @@ def start(loop, args):
     sslctx = None
     if args.tls:
         d.print('using dummy SSLContext')
-        sslctx = asyncio.test_utils.dummy_ssl_context()
+        sslctx = test_utils.dummy_ssl_context()
     r, w = yield from asyncio.open_connection(args.host, args.port, ssl=sslctx)
     d.print('r =', r)
     d.print('w =', w)

examples/subprocess_attach_write_pipe.py

@@ -5,6 +5,7 @@
 import sys
 
 import asyncio
+from asyncio.subprocess import PIPE
 
 code = """
 import os, sys
@@ -23,7 +24,7 @@ def task():
     proc = yield from asyncio.create_subprocess_exec(
                           *args,
                           pass_fds={rfd},
-                          stdout=asyncio.subprocess.PIPE)
+                          stdout=PIPE)
 
     pipe = open(wfd, 'wb', 0)
     transport, _ = yield from loop.connect_write_pipe(asyncio.Protocol,