#NEWLINE# def iter_changes( self , since , forever ) : #NEWLINE# #INDENT# extra_args = ( { #NEWLINE# #INDENT# 'feed' : 'continuous' , #NEWLINE# #UNINDENT# } if forever else { #NEWLINE# #INDENT# #NEWLINE# #UNINDENT# } ) #NEWLINE# extra_args . update ( self . _extra_couch_view_params ) #NEWLINE# changes_stream = ChangesStream ( db = self . _couch_db , heartbeat = True , since = since , filter = changes_stream . _couch_filter , include_docs = self . _include_docs , ** extra_args ) #NEWLINE# for couch_change in changes_stream : #NEWLINE# #INDENT# ( yield change_from_couch_row ( couch_change , document_store = self . _document_store ) )