git.iko.soy/distributed-process
on master help sign in
Fix receiverPump
b4a6326Nicolas Wu
distributed-process/src/Control/Distributed/Process.hs+1−1
compare with master
unifiedsplit
@@ -148,8 +148,8 @@ forkProcess node (Process action) = do
148 receiverPump chan queue = do
148 receiverPump chan queue = do
149 msgBlobs <- Trans.receive chan
149 msgBlobs <- Trans.receive chan
150 let (typerep, body) = read (concatMap BS.unpack msgBlobs)
150 let (typerep, body) = read (concatMap BS.unpack msgBlobs)
151−-- print ("receiverPump", typerep, body)
152 enqueue queue (Message typerep body)
151 enqueue queue (Message typerep body)
152+ receiverPump chan queue
153
153
154send :: (Typeable a, Show a) => ProcessId -> a -> Process ()
154send :: (Typeable a, Show a) => ProcessId -> a -> Process ()
155send (ProcessId chan _ _) msg =
155send (ProcessId chan _ _) msg =