rx/core/observablebase.py
def do_action(self, on_next=None, on_error=None, on_completed=None) -> 'ObservableBase':
        """Invokes an action for each element in the observable sequence
        and invokes an action on graceful or exceptional termination of
        the observable sequence. This method can be used for debugging,
        logging, etc. of query behavior by intercepting the message
        stream to run arbitrary actions for messages on the pipeline.

        1 - observable.do_action(send)
        2 - observable.do_action(on_next, on_error)
        3 - observable.do_action(on_next, on_error, on_completed)

        on_next -- [Optional] Action to invoke for each element in the
            observable sequence.
        on_error -- [Optional] Action to invoke on exceptional termination
            of the observable sequence.
        on_completed -- [Optional] Action to invoke on graceful termination
            of the observable sequence.

        Returns the source sequence with the side-effecting behavior
        applied.
        """
        from ..operators.observable.do import do_action
        return do_action(self, on_next, on_error, on_completed)
Invokes an action for each element in the observable sequence
        and invokes an action on graceful or exceptional termination of
        the observable sequence. This method can be used for debugging,
        logging, etc. of query behavior by intercepting the message
        stream to run arbitrary actions for messages on the pipeline.

        1 - observable.do_action(send)
        2 - observable.do_action(on_next, on_error)
        3 - observable.do_action(on_next, on_error, on_completed)

        on_next -- [Optional] Action to invoke for each element in the
            observable sequence.
        on_error -- [Optional] Action to invoke on exceptional termination
            of the observable sequence.
        on_completed -- [Optional] Action to invoke on graceful termination
            of the observable sequence.

        Returns the source sequence with the side-effecting behavior
        applied.
        
Invokes an action for each element in the observable sequence
and invokes an action on graceful or exceptional termination of
the observable sequence. This method can be used for debugging,
logging, etc. of query behavior by intercepting the message
stream to run arbitrary actions for messages on the pipeline.



- [Optional] Action to invoke for each element in the
observable sequence.
on_error -- [Optional] Action to invoke on exceptional termination
of the observable sequence.
on_completed -- [Optional] Action to invoke on graceful termination
of the observable sequence.

Returns the source sequence with the side-effecting behavior
applied.
Invokes an action for each element in the observable sequence and invokes an action on graceful or exceptional termination of the observable sequence . This method can be used for debugging logging etc . of query behavior by intercepting the message stream to run arbitrary actions for messages on the pipeline . - [ Optional ] Action to invoke for each element in the observable sequence . on_error -- [ Optional ] Action to invoke on exceptional termination of the observable sequence . on_completed -- [ Optional ] Action to invoke on graceful termination of the observable sequence . Returns the source sequence with the side - effecting behavior applied .
def do_action(self, on_next=None, on_error=None, on_completed=None) -> 'ObservableBase':
        from ..operators.observable.do import do_action
        return do_action(self, on_next, on_error, on_completed)
def do_action ( self , on_next = None , on_error = None , on_completed = None ) -> 'ObservableBase' : from . . operators . observable . do import do_action return do_action ( self , on_next , on_error , on_completed )
Invokes an action for each element in the observable sequence
and invokes an action on graceful or exceptional termination of
the observable sequence.
Invokes an action for each element in the observable sequence and invokes an action on graceful or exceptional termination of the observable sequence .
"""Invokes an action for each element in the observable sequence
        and invokes an action on graceful or exceptional termination of
        the observable sequence. This method can be used for debugging,
        logging, etc. of query behavior by intercepting the message
        stream to run arbitrary actions for messages on the pipeline.

        1 - observable.do_action(send)
        2 - observable.do_action(on_next, on_error)
        3 - observable.do_action(on_next, on_error, on_completed)

        on_next -- [Optional] Action to invoke for each element in the
            observable sequence.
        on_error -- [Optional] Action to invoke on exceptional termination
            of the observable sequence.
        on_completed -- [Optional] Action to invoke on graceful termination
            of the observable sequence.

        Returns the source sequence with the side-effecting behavior
        applied.
        """
self
on_next
on_error
on_completed