examples/sim/dataflow: update to new APIs

diff --git a/examples/sim/dataflow.py b/examples/sim/dataflow.py
index 42863f92004a71d2fd19926abf6af2471236a49c..66021ceb6213f4a9367e40f700afc29cf1ce11ab 100644 (file)
--- a/examples/sim/dataflow.py
+++ b/examples/sim/dataflow.py
@@ -23,7 +23,7 @@ def main():
        g.add_connection(source, sink)
        comp = CompositeActor(g)
        def end_simulation(s):
-               s.interrupt = source.actor.done
+               s.interrupt = source.actor.token_exchanger.done
        fragment = comp.get_fragment() + Fragment(sim=[end_simulation])
        sim = Simulator(fragment, Runner())
        sim.run()