search

dbrattli / aioreactive

Async/await reactive tools for Python 3.11+
MIT License
350 stars 24 forks source link

Errors with adispose() #13

Closed nmiculinic closed 3 years ago

nmiculinic commented 6 years ago 

<CoroWrapper Merge.Sink.cancel() running at /usr/local/lib/python3.6/site-packages/aioreactive/operators/merge.py:36, created at /usr/local/lib/python3.6/asyncio/coroutines.py:84> was never yielded from
Coroutine object created at (most recent call last):
...
  File "/usr/local/lib/python3.6/site-packages/aioreactive/core/disposables.py", line 24, in adispose
    await disposable.adispose()
  File "/usr/local/lib/python3.6/asyncio/coroutines.py", line 109, in __next__
    return self.gen.send(None)
  File "/usr/local/lib/python3.6/site-packages/aioreactive/core/disposables.py", line 14, in adispose
    await self._dispose()
  File "/usr/local/lib/python3.6/asyncio/coroutines.py", line 109, in __next__
    return self.gen.send(None)
  File "/usr/local/lib/python3.6/site-packages/aioreactive/core/streams.py", line 66, in adispose
    self.cancel()
  File "/usr/local/lib/python3.6/asyncio/coroutines.py", line 84, in debug_wrapper
    return CoroWrapper(gen, None)
dbrattli commented 6 years ago

Thanks, will look into this

dbrattli commented 3 years ago

Disposables are not part of aioreactive anymore since we are now using Expression. If you have problems like this with the latest release then feel free to open a new issue.