rx/core/observable.py
def to_async(func: Callable, scheduler=None) -> Callable:
        """Converts the function into an asynchronous function. Each
        invocation of the resulting asynchronous function causes an
        invocation of the original synchronous function on the specified
        scheduler.

        Example:
        res = Observable.to_async(lambda x, y: x + y)(4, 3)
        res = Observable.to_async(lambda x, y: x + y, Scheduler.timeout)(4, 3)
        res = Observable.to_async(lambda x: log.debug(x),
                                Scheduler.timeout)('hello')

        func -- Function to convert to an asynchronous function.
        scheduler -- [Optional] Scheduler to run the function on. If not
            specified, defaults to Scheduler.timeout.

        Returns asynchronous function.
        """
        from ..operators.observable.toasync import to_async
        return to_async(func, scheduler)
Converts the function into an asynchronous function. Each
        invocation of the resulting asynchronous function causes an
        invocation of the original synchronous function on the specified
        scheduler.

        Example:
        res = Observable.to_async(lambda x, y: x + y)(4, 3)
        res = Observable.to_async(lambda x, y: x + y, Scheduler.timeout)(4, 3)
        res = Observable.to_async(lambda x: log.debug(x),
                                Scheduler.timeout)('hello')

        func -- Function to convert to an asynchronous function.
        scheduler -- [Optional] Scheduler to run the function on. If not
            specified, defaults to Scheduler.timeout.

        Returns asynchronous function.
        
Converts the function into an asynchronous function. Each
invocation of the resulting asynchronous function causes an
invocation of the original synchronous function on the specified
scheduler.
Converts the function into an asynchronous function . Each invocation of the resulting asynchronous function causes an invocation of the original synchronous function on the specified scheduler .
def to_async(func: Callable, scheduler=None) -> Callable:
        from ..operators.observable.toasync import to_async
        return to_async(func, scheduler)
def to_async ( func : Callable , scheduler = None ) -> Callable : from . . operators . observable . toasync import to_async return to_async ( func , scheduler )
Converts the function into an asynchronous function.
Converts the function into an asynchronous function .
"""Converts the function into an asynchronous function. Each
        invocation of the resulting asynchronous function causes an
        invocation of the original synchronous function on the specified
        scheduler.

        Example:
        res = Observable.to_async(lambda x, y: x + y)(4, 3)
        res = Observable.to_async(lambda x, y: x + y, Scheduler.timeout)(4, 3)
        res = Observable.to_async(lambda x: log.debug(x),
                                Scheduler.timeout)('hello')

        func -- Function to convert to an asynchronous function.
        scheduler -- [Optional] Scheduler to run the function on. If not
            specified, defaults to Scheduler.timeout.

        Returns asynchronous function.
        """
func
Callable
scheduler
examples
None