From: Mart Lubbers <mart@martlubbers.net>
Date: Mon, 2 Mar 2020 15:33:32 +0000 (+0100)
Subject: .
X-Git-Url: https://git.martlubbers.net/?a=commitdiff_plain;h=9b5c1b2bb69cf3c13c1d2c9cdbd5f92464cc7312;p=clean-tests.git

.
---

diff --git a/cloudiTasks/cloudiTasks.icl b/cloudiTasks/cloudiTasks.icl
index 2693038..b80d5b0 100644
--- a/cloudiTasks/cloudiTasks.icl
+++ b/cloudiTasks/cloudiTasks.icl
@@ -3,7 +3,6 @@ module cloudiTasks
 import Data.Func, Data.Functor, Data.Tuple
 import StdEnv
 import iTasks
-import iTasks.Extensions.DateTime
 
 Start w = doTasks master w
 
@@ -12,10 +11,10 @@ master
 	= get applicationOptions
 	>>- \eo->traceValue ("Master started on port " +++ toString eo.serverPort)
 //	>-| asyncTask (ExistingNode "localhost" 9099) (blockWait 5)
-	>-| asyncTask (PrivateNode 9099) (blockWait 5)
+//	>-| asyncTask "localhost" 9090 (blockWait 5)
 //	>-| asyncTask (PrivateNode 9099) (traceValue 5 >-| traceValue 42)
-//	>-| asyncTask (PrivateNode 9099) (updateInformation [] 42)
-//	>-| sleepSortPar [5,1,3,8]
+//	>-| asyncTaskSpawn 9099 (return 42)
+	>-| sleepSortPar [5,1,3,8]
 	>&^ viewSharedInformation []
 	@! ()
 
@@ -30,11 +29,11 @@ where
 sleepSortPar :: [Int] -> Task [Int]
 sleepSortPar numbers = parallel
 	[ (Embedded, \stl->
-		    asyncTask (PrivateNode port) (blockWait num)
+		    asyncTaskSpawn port (blockWait num)
 		>-| appendTask Embedded (\_->return num) stl
 		@? const NoValue)
 	\\ num  <- numbers
-	&  port <- [9091..9099]
+	&  port <- [9092..9099]
 	] [] @? \tv->case tv of
 		NoValue = NoValue
 		(Value ts _)