fixing ToFuture: dispose was done too late

broqer/op/to_future.py

@@ -47,7 +47,6 @@ def _timeout(self):
         self.set_exception(asyncio.TimeoutError)
 
     def _future_done(self, future):
-        self._disposable.dispose()
         if self._timeout_handle is not None:
             self._timeout_handle.cancel()
 
@@ -57,6 +56,7 @@ def emit(self, *args: Any, who: Publisher) -> None:
         assert not hasattr(self, '_disposable') or \
             who == self._disposable._publisher, \
             'emit comming from non assigned publisher'
+        self._disposable.dispose()
         if len(args) == 1:
             self.set_result(args[0])
         else:

setup.cfg

@@ -3,13 +3,13 @@ current_version = 0.3.0-dev
 commit = True
 tag = True
 parse = (?P<major>\d+)\.(?P<minor>\d+).(?P<patch>\d+)(-(?P<release>[a-z]+))?
-serialize = 
+serialize =
 	{major}.{minor}.{patch}-{release}
 	{major}.{minor}.{patch}
 
 [bumpversion:part:release]
 optional_value = gamma
-values = 
+values =
 	dev
 	gamma