diff --git a/streamable/iters.py b/streamable/iters.py index 0f554f2..343aa94 100644 --- a/streamable/iters.py +++ b/streamable/iters.py @@ -356,7 +356,7 @@ def _context_manager(self) -> ContextManager: ... def _launch_future( self, elem: T ) -> "Future[Union[U, RaisingIterator.ExceptionContainer]]": ... - @abstractmethod + @abstractmethod def _get_result( self, futures: "Deque[Future[Union[U, RaisingIterator.ExceptionContainer]]]"