#NEWLINE# def __call__( self , stream ) : #NEWLINE# #INDENT# 'Run the pipeline\n\n        Return a static (non generator) version of the result\n        ' #NEWLINE# for filter in self : #NEWLINE# #INDENT# if callable ( filter ) : #NEWLINE# #INDENT# stream = filter ( stream ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# stream = filter . process ( None , stream ) #NEWLINE# #UNINDENT# #UNINDENT# if isinstance ( stream , GeneratorType ) : #NEWLINE# #INDENT# return list ( stream ) #NEWLINE# #UNINDENT# return stream