use wait instead of as_completed

streamable/iters.py

@@ -3,7 +3,13 @@
 from abc import ABC, abstractmethod
 from asyncio import AbstractEventLoop, get_event_loop
 from collections import defaultdict, deque
-from concurrent.futures import Executor, Future, ThreadPoolExecutor, as_completed
+from concurrent.futures import (
+    FIRST_COMPLETED,
+    Executor,
+    Future,
+    ThreadPoolExecutor,
+    wait,
+)
 from contextlib import contextmanager
 from datetime import datetime
 from math import ceil
@@ -424,9 +430,10 @@ def _get_result(
         if self.ordered:
             return futures.popleft().result()
         else:
-            future = next(as_completed(futures))
-            futures.remove(future)
-            return future.result()
+            done_futures, _ = wait(futures, return_when=FIRST_COMPLETED)
+            done_future = next(iter(done_futures))
+            futures.remove(done_future)
+            return done_future.result()
 
 
 class AsyncConcurrentMappingIterable(ConcurrentMappingIterable[T, U]):
@@ -476,9 +483,9 @@ def _get_result(
             done_futures, _ = self.loop.run_until_complete(
                 asyncio.wait(futures, return_when=asyncio.FIRST_COMPLETED)  # type: ignore
             )
-            future = next(iter(done_futures))
-            futures.remove(future)
-            return future.result()
+            done_future = next(iter(done_futures))
+            futures.remove(done_future)
+            return done_future.result()
 
 
 class ConcurrentFlatteningIterable(