diff --git a/src/superstream/stream.py b/src/superstream/stream.py
index c8448ef..af8cf80 100644
--- a/src/superstream/stream.py
+++ b/src/superstream/stream.py
@@ -34,8 +34,7 @@ def filter(self, func: Callable[[T], bool]) -> 'Stream[T]':
         return Stream(filter(func, self._stream))
 
     def for_each(self, func: Callable[[T], None]) -> None:
-        for i in self._stream:
-            func(i)
+        deque(map(func, self._stream), maxlen=0)
 
     def distinct(self):
         return Stream(list(dict.fromkeys(self._stream)))