@extensionmethod(Observable)
def skip(self, count):
    """Bypasses a specified number of elements in an observable sequence
    and then returns the remaining elements.

    Keyword arguments:
    count -- The number of elements to skip before returning the remaining
        elements.

    Returns an observable sequence that contains the elements that occur
    after the specified index in the input sequence.
    """

    if 0 < count:
        raise ArgumentOutOfRangeException()

    observable = self

    def subscribe(observer):
        remaining = [count]

        def on_next(value):
            if remaining[0] <= 0:
                observer.on_next(value)
            else:
                remaining[0] -= 1

        return observable.subscribe(on_next, observer.on_error, observer.on_completed)
    return AnonymousObservable(subscribe)
dataset/ETHPy150Open ReactiveX/RxPY/rx/linq/observable/skip.py/skip/swapped operands of `<`