diff --git a/pystreamapi/_streams/__parallel_stream.py b/pystreamapi/_streams/__parallel_stream.py
index c763698..2cc2ada 100644
--- a/pystreamapi/_streams/__parallel_stream.py
+++ b/pystreamapi/_streams/__parallel_stream.py
@@ -56,8 +56,9 @@ def process_element(element):
 
     @terminal
     def for_each(self, action: Callable):
-        Parallel(n_jobs=-1, prefer="threads", handler=self)\
-            (delayed(self.__mapper(action))(element) for element in self._source)
+        Parallel(n_jobs=-1, prefer="threads", handler=self)(
+            delayed(self.__mapper(action))(element) for element in self._source
+        )
 
     def _map(self, mapper: Callable[[Any], Any]):
         self._source = Parallel(n_jobs=-1, prefer="threads", handler=self)(