@@ -133,14 +133,16 @@ demo4 mktrans = do
133 sourceEnd1 <- connect sourceAddr1
133 sourceEnd1 <- connect sourceAddr1
134 sourceEnd2 <- connect sourceAddr2
134 sourceEnd2 <- connect sourceAddr2
136− send sourceEnd1 [BS.pack "hello1"]
136+ threadId3 <- forkIO $ forM_ [1..10] $ \i -> send sourceEnd1 [BS.pack ("A" ++ show i)]
137− send sourceEnd2 [BS.pack "hello2"]
137+ threadId4 <- forkIO $ forM_ [1..10] $ \i -> send sourceEnd2 [BS.pack ("B" ++ show i)]
139− threadDelay 100000
139+ threadDelay 1000000
141 putStrLn "demo4: Time, up, killing threads & closing transports.."
141 putStrLn "demo4: Time, up, killing threads & closing transports.."
142 killThread threadId1
142 killThread threadId1
143 killThread threadId2
143 killThread threadId2
144+ killThread threadId3
145+ killThread threadId4
144 putStrLn "demo4: Threads killed."
146 putStrLn "demo4: Threads killed."
145 closeTransport trans
147 closeTransport trans
146 putStrLn "demo4: Done."
148 putStrLn "demo4: Done."