Fixed Pipe implementation

2026-06-22 07:01:18 +03:00 · 2011-07-11 09:11:48 +03:00
parent c5658266fc
commit 6903f4ca29
1 changed files with 1 additions and 1 deletions
@@ -1628,7 +1628,7 @@ namespace Amib.Threading
        public void Pipe<T>(T pipeState, IEnumerable<Action<T>> actions)
        {
            WIGStartInfo wigStartInfo = new WIGStartInfo { StartSuspended = true };
-            IWorkItemsGroup workItemsGroup = CreateWorkItemsGroup(int.MaxValue, wigStartInfo);
+            IWorkItemsGroup workItemsGroup = CreateWorkItemsGroup(1, wigStartInfo);
            foreach (Action<T> action in actions)
            {
                Action<T> act = action;