from __future__ import print_function

from rx import Observable, AnonymousObservable
from rx.internal import extensionmethod


@extensionmethod(Observable)
def dump(self, name = "test"):
    """Debug method for inspecting an observable sequence

    Keyword parameters:
    name -- [Optional] A name to make it easier to match the debug output if
        you insert multiple dumps into the same observable sequence.

    Return an unmodified observable sequence
    """

    def subscribe(observer):
        def on_next(value):
            print("{%s}-->{%s}" % (name, value))
            observer.on_next(value)
        def on_error(ex):
            print("{%s} error -->{%s}" % (name, ex))
            observer.on_error(ex)
        def on_completed():
            print("{%s} completed" % name)
            observer.on_completed()

        return self.subscribe(on_next, on_error, on_completed)
    return AnonymousObservable(subscribe)


e0d3dd588b5e842e01a76152b3b5552e68b74b51
<mask token>

<mask token>


@extensionmethod(Observable)
def dump(self, name='test'):
    """Debug method for inspecting an observable sequence

    Keyword parameters:
    name -- [Optional] A name to make it easier to match the debug output if
        you insert multiple dumps into the same observable sequence.

    Return an unmodified observable sequence
    """

    def subscribe(observer):

        def on_next(value):
            print('{%s}-->{%s}' % (name, value))
            observer.on_next(value)

        def on_error(ex):
            print('{%s} error -->{%s}' % (name, ex))
            observer.on_error(ex)

        def on_completed():
            print('{%s} completed' % name)
            observer.on_completed()
        return self.subscribe(on_next, on_error, on_completed)
    return AnonymousObservable(subscribe)

from __future__ import print_function
from rx import Observable, AnonymousObservable
from rx.internal import extensionmethod


@extensionmethod(Observable)
def dump(self, name='test'):
    """Debug method for inspecting an observable sequence

    Keyword parameters:
    name -- [Optional] A name to make it easier to match the debug output if
        you insert multiple dumps into the same observable sequence.

    Return an unmodified observable sequence
    """

    def subscribe(observer):

        def on_next(value):
            print('{%s}-->{%s}' % (name, value))
            observer.on_next(value)

        def on_error(ex):
            print('{%s} error -->{%s}' % (name, ex))
            observer.on_error(ex)

        def on_completed():
            print('{%s} completed' % name)
            observer.on_completed()
        return self.subscribe(on_next, on_error, on_completed)
    return AnonymousObservable(subscribe)

from __future__ import print_function

from rx import Observable, AnonymousObservable
from rx.internal import extensionmethod


@extensionmethod(Observable)
def dump(self, name = "test"):
    """Debug method for inspecting an observable sequence

    Keyword parameters:
    name -- [Optional] A name to make it easier to match the debug output if
        you insert multiple dumps into the same observable sequence.

    Return an unmodified observable sequence
    """

    def subscribe(observer):
        def on_next(value):
            print("{%s}-->{%s}" % (name, value))
            observer.on_next(value)
        def on_error(ex):
            print("{%s} error -->{%s}" % (name, ex))
            observer.on_error(ex)
        def on_completed():
            print("{%s} completed" % name)
            observer.on_completed()

        return self.subscribe(on_next, on_error, on_completed)
    return AnonymousObservable(subscribe)

