<s> from rx import Observable <EOL> from rx . internal import extensionmethod <EOL> @ extensionmethod ( Observable , alias = "<STR_LIT>" ) <EOL> def reduce ( self , accumulator , seed = None ) : <EOL> """<STR_LIT>""" <EOL> if seed is not None : <EOL> return self . scan ( accumulator , seed = seed ) . start_with ( seed ) . last ( ) <EOL> else : <EOL> return self . scan ( accumulator ) . last ( ) </s>
