From 12c56a0845a7b8e5cbff6ed20eae8b3fa3e26b2d Mon Sep 17 00:00:00 2001 From: Josh Blum Date: Tue, 6 Nov 2012 21:52:30 -0800 Subject: consume and produce calls do it in-place --- tests/block_test.py | 14 +++----------- 1 file changed, 3 insertions(+), 11 deletions(-) (limited to 'tests/block_test.py') diff --git a/tests/block_test.py b/tests/block_test.py index a6dccfc..c62ea6f 100644 --- a/tests/block_test.py +++ b/tests/block_test.py @@ -31,19 +31,11 @@ class VectorSource(gras.Block): def work(self, ins, outs): print 'vector source work' num = min(len(outs[0]), len(self._vec)) - if num == 0: - self.mark_done() - return - #print 'outs[0][:num] is ' - #print len(outs) - #print len(outs[0]) - #print outs[0][0] - #print outs[0][:num] outs[0][:num] = self._vec[:num] self.produce(0, num) self._vec = self._vec[num:] - #if not self._vec: - # self.mark_done() + if not self._vec: + self.mark_done() print 'vector source work done' class VectorSink(gras.Block): @@ -84,7 +76,7 @@ class BlockTest(unittest.TestCase): vec_sink = None def test_make_block(self): - return + #return null_src = NullSource() null_sink = NullSink() -- cgit