File tree 1 file changed +4
-4
lines changed
1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -26,17 +26,17 @@ searches for a list of peer nodes, and sends a message to a registered (named) p
26
26
{% highlight haskell %}
27
27
import System.Environment (getArgs)
28
28
import Control.Distributed.Process
29
- import Control.Distributed.Process.Node (initRemoteTable)
29
+ import Control.Distributed.Process.Node (initRemoteTable, runProcess )
30
30
import Control.Distributed.Process.Backend.SimpleLocalnet
31
- import Control.Monad (forever, mapM _ )
31
+ import Control.Monad (forever, forM _ )
32
32
33
33
main = do
34
34
[ host, port] <- getArgs
35
35
36
36
backend <- initializeBackend host port initRemoteTable
37
37
node <- newLocalNode backend
38
- runProcess node $ forever $ do
39
- findPeers backend >>= mapM _ $ \peer -> nsendRemote peer "echo-server" "hello!"
38
+ peers <- findPeers backend 1000000
39
+ runProcess node $ forM _ peers $ \peer -> nsendRemote peer "echo-server" "hello!"
40
40
41
41
{% endhighlight %}
42
42
You can’t perform that action at this time.
0 commit comments