chain.py

    def test_filter_pipeline_chaining(self):
        fp = FilterPipeline([
            DirectionalFilter('inbound').chain(
                MSISDNFilter('from_addr', '+27817030792')),
            TimestampFilter('2013-09-10 00:00:00', '2013-09-10 23:59:59')
        ])
        stdin = StringIO(self.SAMPLE)
        stdout = StringIO()
        fp.process(stdin=stdin, stdout=stdout)
        self.assertEqual(stdout.getvalue(), self.HEADER + self.INBOUND)