Typing

type reactivex.typing.AnyFuture = Future[_T1] | Future[_T1]

Any future-like object, i.e. either an asyncio.Future or a concurrent.futures.Future. Both provide the add_done_callback, result and cancel methods that RxPY needs in order to lift a future into an Observable.