change default multitask syntax to use green threads

Author: czheo

syntax_sugar/pipe.py

@@ -120,7 +120,7 @@ def __or__(self, rhs):
                 raise SyntaxError('Bad pipe multiprocessing syntax.')
             poolsize = len(rhs)
             new_action = rhs[0]
-            self.action = compose(partial(multithread, new_action, poolsize), self.action)
+            self.action = compose(partial(multigreenthread, new_action, poolsize), self.action)
         elif isinstance(rhs, ProcessSyntax):
             self.action = compose(partial(multiprocess, rhs.func, rhs.poolsize), self.action)
         elif isinstance(rhs, ThreadSyntax):

tests/test_pipe.py

@@ -33,11 +33,11 @@ def test_pipe_multiprocess():
     assert pipe(100) | range | p[lambda x: x**2] * 3 | sorted | END == [x ** 2 for x in range(100)]
 
 def test_pipe_multithread():
-    assert pipe(100) | range | [lambda x: x**2] * 3 | sorted | END == [x ** 2 for x in range(100)]
     assert pipe(100) | range | t[lambda x: x**2] * 3 | sorted | END == [x ** 2 for x in range(100)]
 
 def test_pipe_multigreenthread():
-    assert pipe(100) | range | g[lambda x: x**2] * 3 | sorted | END == [x ** 2 for x in range(100)]
+    assert pipe(10000) | range | [lambda x: x**2] * 10000 | sorted | END == [x ** 2 for x in range(10000)]
+    assert pipe(10000) | range | g[lambda x: x**2] * 10000 | sorted | END == [x ** 2 for x in range(10000)]
 
 def test_redirect():
     p = pipe(range(10)) | each(str) | ''.join