From 0cbd9b7c4b99b7e51b6212bef5ffa3429bb92533 Mon Sep 17 00:00:00 2001 From: Paul Louth Date: Fri, 14 Feb 2025 19:18:59 +0000 Subject: [PATCH] Refactor QueueExample to simplify consumer logic --- Samples/EffectsExamples/Examples/QueueExample.cs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/Samples/EffectsExamples/Examples/QueueExample.cs b/Samples/EffectsExamples/Examples/QueueExample.cs index 83d05278b..2b7096a3a 100644 --- a/Samples/EffectsExamples/Examples/QueueExample.cs +++ b/Samples/EffectsExamples/Examples/QueueExample.cs @@ -39,7 +39,7 @@ public static Eff main() // Run the queues in a forked task // Repeatedly read from the console and write to one of the two queues depending on // whether the first char is 1 or 2 - var effect = from f in fork(Producer.merge(queues) | Consumer.repeat(writeLine)) + var effect = from f in fork(Producer.merge(queues) | writeLine) from x in Console.readLines | writeToQueue(queue1, queue2) | Schedule.Forever from _ in f.Cancel // cancels the forked task select unit;