From 01e4a0ef39ee9d9e7dd56bd875625c3ce6a0dec8 Mon Sep 17 00:00:00 2001 From: Tomas Farago Date: Sun, 21 Sep 2014 23:08:29 +0200 Subject: [PATCH] Test process filter --- concert/tests/unit/test_coroutines.py | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/concert/tests/unit/test_coroutines.py b/concert/tests/unit/test_coroutines.py index d5d3f63c4..a07687cca 100644 --- a/concert/tests/unit/test_coroutines.py +++ b/concert/tests/unit/test_coroutines.py @@ -1,7 +1,8 @@ import numpy as np from concert.coroutines.base import coroutine, broadcast, inject from concert.coroutines.filters import (absorptivity, backproject, flat_correct, average_images, - queue, sinograms, downsize, stall, PickSlice, Timer) + queue, sinograms, downsize, stall, PickSlice, Timer, + process) from concert.coroutines.sinks import null, Result, Accumulate from concert.tests import assert_almost_equal, TestCase @@ -155,6 +156,11 @@ def test_accumulate(self): inject(generator(), accumulate()) self.assertEqual(accumulate.items, range(5)) + def test_process(self): + result = Result() + inject((1,), process(lambda x: -x, result())) + self.assertEqual(-1, result.result) + class TestTimer(TestCase):