Skip to content

Commit d3a18e8

Browse files
committed
FDFOAsyncFutureResultCollection: remove _waiter
1 parent bb8c7ec commit d3a18e8

File tree

1 file changed

+0
-2
lines changed

1 file changed

+0
-2
lines changed

streamable/util/futuretools.py

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -132,11 +132,9 @@ def _done_callback(self, future: "Future[T]") -> None:
132132
def __next__(self) -> T:
133133
result = self.event_loop.run_until_complete(self._results.get())
134134
self._n_futures -= 1
135-
self._waiter = self.event_loop.create_future()
136135
return result
137136

138137
async def __anext__(self) -> T:
139138
result = await self._results.get()
140139
self._n_futures -= 1
141-
self._waiter = self.event_loop.create_future()
142140
return result

0 commit comments

Comments
 (0)