From c7718b3ddd4ea80f089a62e180d0dafdd47b765a Mon Sep 17 00:00:00 2001 From: Tony Garnock-Jones Date: Mon, 31 May 2021 12:05:00 +0200 Subject: [PATCH] Make turns atomic, rather than reply-turn-per-event --- src/main/java/org/syndicate_lang/actors/Turn.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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;