diff --git a/src/main/java/org/syndicate_lang/actors/Turn.java b/src/main/java/org/syndicate_lang/actors/Turn.java index 1f7d9ca..b482261 100644 --- a/src/main/java/org/syndicate_lang/actors/Turn.java +++ b/src/main/java/org/syndicate_lang/actors/Turn.java @@ -36,7 +36,7 @@ public class Turn { private void commit() { if (_pending != null) { - _pending.forEach((ac, q) -> ac.execute(() -> q.forEach(f -> Turn.forActor(ac, f)))); + _pending.forEach((ac, q) -> ac.execute(() -> Turn.forActor(ac, t -> q.forEach(f -> f.accept(t))))); _pending = null; } _complete = true;