<s> from rx import Observable , AnonymousObservable <EOL> from rx . internal import ArgumentOutOfRangeException <EOL> from rx . internal import extensionmethod <EOL> @ extensionmethod ( Observable ) <EOL> def skip ( self , count ) : <EOL> """<STR_LIT>""" <EOL> if count < <NUM_LIT:0> : <EOL> raise ArgumentOutOfRangeException ( ) <EOL> observable = self <EOL> def subscribe ( observer ) : <EOL> remaining = [ count ] <EOL> def on_next ( value ) : <EOL> if remaining [ <NUM_LIT:0> ] <= <NUM_LIT:0> : <EOL> observer . on_next ( value ) <EOL> else : <EOL> remaining [ <NUM_LIT:0> ] -= <NUM_LIT:1> <EOL> return observable . subscribe ( on_next , observer . on_error , observer . on_completed ) <EOL> return AnonymousObservable ( subscribe ) </s>
