rx/core/observablebase.py
def observe_on(self, scheduler: abc.Scheduler) -> 'ObservableBase':
        """Wraps the source sequence in order to run its observer callbacks on
        the specified scheduler.

        Keyword arguments:
        scheduler -- Scheduler to notify observers on.

        Returns the source sequence whose observations happen on the specified
        scheduler.

        This only invokes observer callbacks on a scheduler. In case the
        subscription and/or unsubscription actions have side-effects
        that require to be run on a scheduler, use subscribe_on.
        """
        from ..operators.observable.observeon import observe_on
        return observe_on(self, scheduler)
Wraps the source sequence in order to run its observer callbacks on
        the specified scheduler.

        Keyword arguments:
        scheduler -- Scheduler to notify observers on.

        Returns the source sequence whose observations happen on the specified
        scheduler.

        This only invokes observer callbacks on a scheduler. In case the
        subscription and/or unsubscription actions have side-effects
        that require to be run on a scheduler, use subscribe_on.
        
Wraps the source sequence in order to run its observer callbacks on
the specified scheduler.

Keyword arguments:
scheduler -- Scheduler to notify observers on.

Returns the source sequence whose observations happen on the specified
scheduler.

This only invokes observer callbacks on a scheduler. In case the
subscription and/or unsubscription actions have side-effects
that require to be run on a scheduler, use subscribe_on.
Wraps the source sequence in order to run its observer callbacks on the specified scheduler . Keyword arguments : scheduler -- Scheduler to notify observers on . Returns the source sequence whose observations happen on the specified scheduler . This only invokes observer callbacks on a scheduler . In case the subscription and / or unsubscription actions have side - effects that require to be run on a scheduler use subscribe_on .
def observe_on(self, scheduler: abc.Scheduler) -> 'ObservableBase':
        from ..operators.observable.observeon import observe_on
        return observe_on(self, scheduler)
def observe_on ( self , scheduler : abc . Scheduler ) -> 'ObservableBase' : from . . operators . observable . observeon import observe_on return observe_on ( self , scheduler )
Wraps the source sequence in order to run its observer callbacks on
the specified scheduler.
Wraps the source sequence in order to run its observer callbacks on the specified scheduler .
"""Wraps the source sequence in order to run its observer callbacks on
        the specified scheduler.

        Keyword arguments:
        scheduler -- Scheduler to notify observers on.

        Returns the source sequence whose observations happen on the specified
        scheduler.

        This only invokes observer callbacks on a scheduler. In case the
        subscription and/or unsubscription actions have side-effects
        that require to be run on a scheduler, use subscribe_on.
        """
self
scheduler
abc.Scheduler