rx/core/observable.py
def start(func: Callable, scheduler: abc.Scheduler = None) -> ObservableBase:
        """Invokes the specified function asynchronously on the specified
        scheduler, surfacing the result through an observable sequence.

        Example:
        res = rx.Observable.start(lambda: pprint('hello'))
        res = rx.Observable.start(lambda: pprint('hello'), rx.Scheduler.timeout)

        Keyword arguments:
        func -- Function to run asynchronously.
        scheduler -- [Optional] Scheduler to run the function on. If not
            specified, defaults to Scheduler.timeout.

        Returns an observable sequence exposing the function's result
        value, or an exception.

        Remarks:
        The function is called immediately, not during the subscription
        of the resulting sequence. Multiple subscriptions to the
        resulting sequence can observe the function's result.
        """
        from ..operators.observable.start import start
        return start(func, scheduler)
Invokes the specified function asynchronously on the specified
        scheduler, surfacing the result through an observable sequence.

        Example:
        res = rx.Observable.start(lambda: pprint('hello'))
        res = rx.Observable.start(lambda: pprint('hello'), rx.Scheduler.timeout)

        Keyword arguments:
        func -- Function to run asynchronously.
        scheduler -- [Optional] Scheduler to run the function on. If not
            specified, defaults to Scheduler.timeout.

        Returns an observable sequence exposing the function's result
        value, or an exception.

        Remarks:
        The function is called immediately, not during the subscription
        of the resulting sequence. Multiple subscriptions to the
        resulting sequence can observe the function's result.
        
Invokes the specified function asynchronously on the specified
scheduler, surfacing the result through an observable sequence.
Invokes the specified function asynchronously on the specified scheduler surfacing the result through an observable sequence .
def start(func: Callable, scheduler: abc.Scheduler = None) -> ObservableBase:
        from ..operators.observable.start import start
        return start(func, scheduler)
def start ( func : Callable , scheduler : abc . Scheduler = None ) -> ObservableBase : from . . operators . observable . start import start return start ( func , scheduler )
Invokes the specified function asynchronously on the specified
scheduler, surfacing the result through an observable sequence.
Invokes the specified function asynchronously on the specified scheduler surfacing the result through an observable sequence .
"""Invokes the specified function asynchronously on the specified
        scheduler, surfacing the result through an observable sequence.

        Example:
        res = rx.Observable.start(lambda: pprint('hello'))
        res = rx.Observable.start(lambda: pprint('hello'), rx.Scheduler.timeout)

        Keyword arguments:
        func -- Function to run asynchronously.
        scheduler -- [Optional] Scheduler to run the function on. If not
            specified, defaults to Scheduler.timeout.

        Returns an observable sequence exposing the function's result
        value, or an exception.

        Remarks:
        The function is called immediately, not during the subscription
        of the resulting sequence. Multiple subscriptions to the
        resulting sequence can observe the function's result.
        """
func
Callable
scheduler
abc.Scheduler
examples
None