Job's __init__ now accepts event as a parameter instead of a function; to spawn a function either use 'spawn' method or spawn_new classmethod

1 files changed, 3 insertions, 18 deletions

diff --git a/examples/connect.py b/examples/connect.py
index 045bc86..33e1e68 100644
--- a/examples/connect.py
+++ b/examples/connect.py
@@ -19,27 +19,12 @@ def geturl(url):
     c.send('GET /\r\n\r\n')
     return c.recv(1024)
 
-def progress_indicator():
-    while True:
-        sys.stderr.write('.')
-        sleep(0.5)
-
-Job(progress_indicator)
-
-urls = ['www.%s.com' % (x*3) for x in string.letters]
-jobs = [Job(geturl, x) for x in urls]
+urls = ['www.google.com', 'www.yandex.ru', 'www.python.org']
+jobs = [Job.spawn_new(geturl, x) for x in urls]
 
 print 'spawned %s jobs' % len(jobs)
 
 # collect the results from workers, one by one
 for url, job in zip(urls, jobs):
-    sys.stderr.write('%s: ' % url)
-    try:
-        result = job.wait()
-    except Exception, ex: # when using BaseException here and pressing Ctrl-C recv returns None sometimes
-        sys.stderr.write('%s' % ex)
-    else:
-        sys.stderr.write('%s bytes: %s...' % (len(result), repr(result)[:40]))
-    finally:
-        sys.stderr.write('\n')
+    print '%s: %s' % (url, repr(job.wait())[:50])