amqp 0.2.4 → 0.2.5

raw patch · 2 files changed

+8/−6 lines, 2 files

Files

Network/AMQP.hs +7/−5
amqp.cabal +1/−1

Network/AMQP.hs view

@@ -705,15 +705,17 @@             then error $ "recvExact wanted "++show bytes++" bytes; got "++show (fromIntegral $ BL.length b)++" bytes"             else return b     recvExact' bytes buf = do-        dat <- NB.recv sock bytes -- (min bytes maxFrameSize)-        if BS.length dat == 0 +        dat <- NB.recv sock bytes+        let len = BS.length dat+        if len == 0             then CE.throwIO $ ConnectionClosedException "recv returned 0 bytes"             else do                 let buf' = BL.append buf (toLazy dat)-                    bufLen = fromIntegral $ BL.length buf'-                if bufLen >= bytes+                if len >= bytes                     then return buf'-                    else recvExact' (bytes-bufLen) buf'+                    else recvExact' (bytes-len) buf'+            +

amqp.cabal view

@@ -1,5 +1,5 @@ Name:                amqp
-Version:             0.2.4
+Version:             0.2.5
 Synopsis:            Client library for AMQP servers (currently only RabbitMQ)
 Description:         Client library for AMQP servers (currently only RabbitMQ)
 License:             BSD3