rx/core/observable.py
def from_future(future: Union[ObservableBase, Future]) -> ObservableBase:
        """Converts a Future to an Observable sequence

        Keyword Arguments:
        future -- A Python 3 compatible future.
            https://docs.python.org/3/library/asyncio-task.html#future
            http://www.tornadoweb.org/en/stable/concurrent.html#tornado.concurrent.Future

        Returns an Observable sequence which wraps the existing future
        success and failure.
        """
        from ..operators.observable.fromfuture import from_future
        return from_future(future)
Converts a Future to an Observable sequence

        Keyword Arguments:
        future -- A Python 3 compatible future.
            https://docs.python.org/3/library/asyncio-task.html#future
            http://www.tornadoweb.org/en/stable/concurrent.html#tornado.concurrent.Future

        Returns an Observable sequence which wraps the existing future
        success and failure.
        
Converts a Future to an Observable sequence
Keyword Arguments:
future -- A Python 3 compatible future.

Returns an Observable sequence which wraps the existing future
success and failure.
Converts a Future to an Observable sequence Keyword Arguments : future -- A Python 3 compatible future . Returns an Observable sequence which wraps the existing future success and failure .
def from_future(future: Union[ObservableBase, Future]) -> ObservableBase:
        from ..operators.observable.fromfuture import from_future
        return from_future(future)
def from_future ( future : Union [ ObservableBase , Future ] ) -> ObservableBase : from . . operators . observable . fromfuture import from_future return from_future ( future )
Converts a Future to an Observable sequence
Keyword Arguments:
future -- A Python 3 compatible future.
Converts a Future to an Observable sequence Keyword Arguments : future -- A Python 3 compatible future .
"""Converts a Future to an Observable sequence

        Keyword Arguments:
        future -- A Python 3 compatible future.
            https://docs.python.org/3/library/asyncio-task.html#future
            http://www.tornadoweb.org/en/stable/concurrent.html#tornado.concurrent.Future

        Returns an Observable sequence which wraps the existing future
        success and failure.
        """
future
Union[ObservableBase, Future]