rx/core/observablebase.py
def to_future(self, future_ctor: Callable[[], Future] = None) -> Future:
        """Converts an existing observable sequence to a Future.

        Example:
        future = Observable.return_value(42).to_future(trollius.Future)

        With config:
        rx.config["Future"] = trollius.Future
        future = Observable.return_value(42).to_future()

        future_ctor -- [Optional] The constructor of the future.
            If not provided, it uses asyncio.Future.

        Returns a future with the last value from the observable
        sequence.
        """
        from ..operators.observable.tofuture import to_future
        return to_future(self, future_ctor)
Converts an existing observable sequence to a Future.

        Example:
        future = Observable.return_value(42).to_future(trollius.Future)

        With config:
        rx.config["Future"] = trollius.Future
        future = Observable.return_value(42).to_future()

        future_ctor -- [Optional] The constructor of the future.
            If not provided, it uses asyncio.Future.

        Returns a future with the last value from the observable
        sequence.
        
Converts an existing observable sequence to a Future.
Converts an existing observable sequence to a Future .
def to_future(self, future_ctor: Callable[[], Future] = None) -> Future:
        from ..operators.observable.tofuture import to_future
        return to_future(self, future_ctor)
def to_future ( self , future_ctor : Callable [ [ ] , Future ] = None ) -> Future : from . . operators . observable . tofuture import to_future return to_future ( self , future_ctor )
Converts an existing observable sequence to a Future.
Converts an existing observable sequence to a Future .
"""Converts an existing observable sequence to a Future.

        Example:
        future = Observable.return_value(42).to_future(trollius.Future)

        With config:
        rx.config["Future"] = trollius.Future
        future = Observable.return_value(42).to_future()

        future_ctor -- [Optional] The constructor of the future.
            If not provided, it uses asyncio.Future.

        Returns a future with the last value from the observable
        sequence.
        """
self
future_ctor
Callable[[], Future]
examples
None