From 6903f4ca29aaa4f1f67c0e38e969136db2d49279 Mon Sep 17 00:00:00 2001
From: Ami Bar <amibar@gmail.com>
Date: Mon, 11 Jul 2011 09:11:48 +0300
Subject: [PATCH] Fixed Pipe implementation

---
 SmartThreadPool/SmartThreadPool.cs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/SmartThreadPool/SmartThreadPool.cs b/SmartThreadPool/SmartThreadPool.cs
index 2b0202f..dab2478 100644
--- a/SmartThreadPool/SmartThreadPool.cs
+++ b/SmartThreadPool/SmartThreadPool.cs
@@ -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;