Test process filter

ufo-kit · Sep 21, 2014 · 01e4a0e · 01e4a0e
1 parent 8fe3f58
commit 01e4a0e
Showing 1 changed file with 7 additions and 1 deletion.
diff --git 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):