recvMsg :: (Receiver a) => IOLoop a -> IO [[B.ByteString]]
recvMsg p = takeMVar (pollInQ p)
recvMsg :: (Receiver a) => IOLoop a -> IO [[B.ByteString]]
recvMsg p = takeMVar (pollInQ p)
recvMsg p = takeMVar (pollInQ p)