ó
|£*^c           @   s*   d  d l  m Z d e f d „  ƒ  YZ d S(   iÿÿÿÿ(   t   GeneratorTypet   Pipelinec           B   s   e  Z d  Z d „  Z RS(   s(   Pipeline to process filters sequentiallyc         C   s[   x; |  D]3 } t  | ƒ r( | | ƒ } q | j d | ƒ } q Wt | t ƒ rW t | ƒ S| S(   sX   Run the pipeline

        Return a static (non generator) version of the result
        N(   t   callablet   processt   Nonet
   isinstanceR    t   list(   t   selft   streamt   filter(    (    se   /home/gitlab-runner/builds/8480fa44/0/bergerc/fluidmanager-web/art-framework/bin/sqlparse/pipeline.pyt   __call__   s    
(   t   __name__t
   __module__t   __doc__R
   (    (    (    se   /home/gitlab-runner/builds/8480fa44/0/bergerc/fluidmanager-web/art-framework/bin/sqlparse/pipeline.pyR   	   s   N(   t   typesR    R   R   (    (    (    se   /home/gitlab-runner/builds/8480fa44/0/bergerc/fluidmanager-web/art-framework/bin/sqlparse/pipeline.pyt   <module>   s   