alemazzo
diff --git a/‎README.md‎
Lines changed: 12 additions & 2 deletions b/‎README.md‎
Lines changed: 12 additions & 2 deletions
diff --git a/‎parallel_test.py‎
Lines changed: 0 additions & 189 deletions b/‎parallel_test.py‎
Lines changed: 0 additions & 189 deletions
diff --git a/‎stream/__init__.py‎
Lines changed: 2 additions & 1 deletion b/‎stream/__init__.py‎
Lines changed: 2 additions & 1 deletion
diff --git a/‎stream/booleans.py‎
Lines changed: 38 additions & 0 deletions b/‎stream/booleans.py‎
Lines changed: 38 additions & 0 deletions
diff --git a/‎stream/numbers.py‎
Lines changed: 114 additions & 0 deletions b/‎stream/numbers.py‎
Lines changed: 114 additions & 0 deletions
@@ -135,9 +135,9 @@ Here some example of how to use Streams:
 Stream.randint(1, 100).limit(100).toList()
 ```
 
-* Generate a list of the numbers from 1 to 100
+* Print the numbers from 1 to 100
 ```py
-Stream.iterate(1, lambda i: i + 1).limit(100).toList()
+Stream.iterate(1, lambda i: i + 1).limit(100).forEach(print)
 ```
 
 * Generate a list of squares of the number from 1 to 100
@@ -150,6 +150,16 @@ Stream.iterate(1, lambda i: i + 1).map(lambda x: x**2).limit(100).toList()
 Stream.generate(lambda: 0).limit(100).toList()
 ```
 
+* Generate a set of the first 100 odds number
+```py
+Stream.odds().limit(100).toSet()
+```
+
+* Generate a list of all the primes number smaller than 100
+```py
+Stream.primes().takeWhile(lambda x: x < 100).toList()
+```
+
 
 
 <!-- ROADMAP -->
 
@@ -1 +1,2 @@
-from .stream import *
+from .stream import Stream
+from .intstream import IntStream
@@ -0,0 +1,38 @@
+from .stream import Stream
+import random
+
+
+class BooleanStream(Stream):
+
+    @staticmethod
+    def random():
+        '''
+        Returns an infinite stream of random booleans
+
+        :return: a random boolean stream
+        '''
+        return BooleanStream(Stream.generate(lambda: random.randint(0, 1) == 1))
+
+    @staticmethod
+    def true():
+        '''
+        Returns an infinite stream of True
+
+        :return: a True boolean stream
+        '''
+        return BooleanStream(Stream.generate(lambda: True))
+
+    @staticmethod
+    def false():
+        '''
+        Returns an infinite stream of False
+
+        :return: a False boolean stream
+        '''
+        return BooleanStream(Stream.generate(lambda: False))
+
+    def __init__(self, _stream):
+        if isinstance(_stream, Stream):
+            self.iterable = _stream.__iterable
+        else:
+            self.iterable = _stream
@@ -0,0 +1,114 @@
+import math
+import random
+
+from .stream import Stream
+
+
+class NumberStream(Stream):
+
+    @staticmethod
+    def integers():
+        '''
+        Returns an infinite stream of integer from 0 to infinity
+
+        :return: the infinite stream
+        '''
+        return NumberStream(Stream.iterate(0, lambda i: i + 1))
+
+    @staticmethod
+    def odds():
+        '''
+        Returns an infinite stream of odds number from 0 to infinity
+
+        :return: the infinite stream
+        '''
+        return NumberStream(Stream.iterate(1, lambda i: i + 2))
+
+    @staticmethod
+    def evens():
+        '''
+        Returns an infinite stream of evens number from 0 to infinity
+
+        :return: the infinite stream
+        '''
+        return NumberStream(Stream.iterate(0, lambda i: i + 2))
+
+    @staticmethod
+    def primes():
+        '''
+        Returns an infinite stream of primes number from 2 to infinity
+
+        :return: the infinite stream
+        '''
+        def prime_generator():
+            yield 2
+            primes = [2]
+            actual = 1
+            while True:
+                actual += 2
+                for prime in primes:
+                    if actual % prime == 0:
+                        break
+                else:
+                    primes.append(actual)
+                    yield actual
+
+        return NumberStream(prime_generator())
+
+    @staticmethod
+    def randint(lower, upper):
+        '''
+        Returns an infinite stream of random integer in range [a, b], including both end points.
+
+        :param int lower: min value for random numbers
+        :param int upper: max value for random numbers
+        :return: the infinite random stream
+        '''
+        return NumberStream(Stream.generate(lambda: random.randint(lower, upper)))
+
+    @staticmethod
+    def random():
+        '''
+        Returns an infinite stream of random numbers in range [0, 1], including both end points.
+
+        :param int lower: min value for random numbers
+        :param int upper: max value for random numbers
+        :return: the infinite random stream
+        '''
+        return NumberStream(Stream.generate(random.random))
+
+    def __init__(self, _stream):
+        if isinstance(_stream, Stream):
+            self.iterable = _stream.iterable
+        else:
+            self.iterable = _stream
+
+    def smallerThan(self, maximum):
+        return self.filter(lambda x: x < maximum)
+
+    def smallerOrEqualThan(self, maximum):
+        return self.filter(lambda x: x <= maximum)
+
+    def greaterThan(self, minimum):
+        return self.filter(lambda x: x > minimum)
+
+    def greaterOrEqualThan(self, minimum):
+        return self.filter(lambda x: x >= minimum)
+
+    def multipleOf(self, number):
+        return self.filter(lambda x: x % number == 0)
+
+    def square(self):
+        return self.pow(2)
+
+    def cube(self):
+        return self.pow(3)
+
+    def pow(self, power):
+        return self.map(lambda x: x ** power)
+
+    def sqrt(self):
+        return self.map(math.sqrt)
+
+    def log(self):
+        return self.map(math.log)
Original file line number	Diff line number	Diff line change
`@@ -1 +1,2 @@`
`1`		`-from .stream import *`
	`1`	`+from .stream import Stream`
	`2`	`+from .intstream import IntStream`