core.py 文件源码

def filter(self, *filters):
        """Apply filters to the stream.

        This method returns a new stream with the given filters applied. The
        filters must be callables that accept the stream object as parameter,
        and return the filtered stream.

        The call::

            stream.filter(filter1, filter2)

        is equivalent to::

            stream | filter1 | filter2

        :param filters: one or more callable objects that should be applied as
                        filters
        :return: the filtered stream
        :rtype: `Stream`
        """
        return reduce(operator.or_, (self,) + filters)