<s> from rx . internal import extensionmethod <EOL> from . controlledobservable import ControlledObservable <EOL> from . windowedobservable import WindowedObservable <EOL> @ extensionmethod ( ControlledObservable ) <EOL> def windowed ( self , window_size ) : <EOL> """<STR_LIT>""" <EOL> return WindowedObservable ( self , window_size ) </s>
