|
|
|
@ -66,7 +66,7 @@ forkQssChannel :: |
|
|
|
forkQssChannel chan = do |
|
|
|
forkQssChannel chan = do |
|
|
|
ch1 <- newBoundedChan 50000 |
|
|
|
ch1 <- newBoundedChan 50000 |
|
|
|
ch2 <- newBoundedChan 50000 |
|
|
|
ch2 <- newBoundedChan 50000 |
|
|
|
tid <- fork $ do |
|
|
|
tid <- fork $ forever $ do |
|
|
|
x <- readChan chan |
|
|
|
x <- readChan chan |
|
|
|
writeChan ch1 x |
|
|
|
writeChan ch1 x |
|
|
|
case x of |
|
|
|
case x of |
|
|
|
|