import Data.Func, Data.Functor, Data.Tuple
import StdEnv
import iTasks
-import iTasks.Extensions.DateTime
Start w = doTasks master w
= 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 []
@! ()
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 _)