@extensionmethod(Observable)
def window_with_count(self, count, skip=None):

    source = self
    if count <= 0:
        raise ArgumentOutOfRangeException()

    if skip is None:
        skip = count

    if skip <= 0:
        raise ArgumentOutOfRangeException()

    def subscribe(observer):
        m = SingleAssignmentDisposable()
        refCountDisposable = RefCountDisposable(m)
        n = [0]
        q = []

        def create_window():
            s = Subject()
            q.append(s)
            observer.on_next(add_ref(s, refCountDisposable))

        create_window()

        def on_next(x):
            for item in q:
                item.on_next(x)

            c = n[0] - count + 1
            if c >= 0 and c % skip == 0:
                s = q.pop(0);
                s.on_completed()

            n[0] += 1
            if (n[0] % skip) == 0:
                create_window()

        def on_error(exception):
            while len(q):
                q.pop(0).on_error(exception)
            observer.on_error(exception)

        def on_completed():
            while len(q):
                q.pop(0).on_completed()
            observer.on_completed()

        m.disposable = source.subscribe(on_next, on_error, on_completed)
        return refCountDisposable
    return AnonymousObservable(subscribe)
Tries to fetch the given subcommand, printing a message with the
dataset/ETHPy150Open ReactiveX/RxPY/rx/linq/observable/windowwithcount.py/window_with_count--crossover with--dataset/ETHPy150Open AppScale/appscale/AppServer/lib/django-1.2/django/core/management/__init__.py/ManagementUtility.fetch_command