polish up work and notify api

There is a formal api to mark done, and IO failures.
Notify topology was created for consistency.

So far, there output fail is unimplemented,
and input fail requires an additional check.

1 files changed, 4 insertions, 8 deletions

diff --git a/tests/block_test.py b/tests/block_test.py
index d510b6e..b598b27 100644
--- a/tests/block_test.py
+++ b/tests/block_test.py
@@ -8,16 +8,16 @@ class NullSource(gras.Block):
         gras.Block.__init__(self, 'NullSource')
         self.set_output_signature([numpy.int32])
 
-    def callback(self, x):
-        print x
+    def work(self, ins, outs):
+        self.mark_done()
 
 class NullSink(gras.Block):
     def __init__(self):
         gras.Block.__init__(self, 'NullSink')
         self.set_input_signature([numpy.int32])
 
-    def callback(self, x):
-        print x
+    def work(self, ins, outs):
+        self.mark_done()
 
 class BlockTest(unittest.TestCase):
 
@@ -26,10 +26,6 @@ class BlockTest(unittest.TestCase):
 
         null_sink = NullSink()
 
-        #null_src.doit(321)
-
-        #return
-
         tb = gras.TopBlock()
 
         print 'connect...'