reader fixes:

catch exceptions while blocking on readTMVar
  catch exceptiosn while waiting for semaphores

src/Network/XMPP/Concurrent/Threads.hs

@@ -29,6 +29,13 @@ import Text.XML.Stream.Elements
 
 import GHC.IO (unsafeUnmask)
 
+-- While waiting for the first semaphore(s) to flip we might receive
+-- another interrupt. When that happens we add it's semaphore to the
+-- list and retry waiting
+handleInterrupts ts =
+    Ex.catch (atomically $ forM ts takeTMVar)
+          ( \(Interrupt t) -> handleInterrupts (t:ts))
+
 readWorker :: TChan (Either MessageError Message)
            -> TChan (Either PresenceError Presence)
            -> TVar IQHandlers
@@ -36,22 +43,25 @@ readWorker :: TChan (Either MessageError Message)
            -> IO ()
 readWorker messageC presenceC handlers stateRef =
     Ex.mask_ . forever $ do
-        s <- liftIO . atomically $ takeTMVar stateRef
+        res <- liftIO $ Ex.catch (
-        (sta', s') <- flip runStateT s $ Ex.catch ( do
+                   Ex.bracket
-                -- we don't know whether pull will necessarily be interruptible
+                       (atomically $ takeTMVar stateRef)
-                                           liftIO $ allowInterrupt
+                       (atomically . putTMVar stateRef )
-                                           Just <$> pull
+                       (\s -> do
+                           -- we don't know whether pull will
+                           -- necessarily be interruptible
+                           allowInterrupt
+                           Just <$> runStateT pull s
+                       )
                    )
                    (\(Interrupt t) -> do
-                                           liftIO . atomically $
+                        handleInterrupts [t]
-                                               putTMVar stateRef s
-                                           liftIO . atomically $ takeTMVar t
                         return Nothing
                    )
         liftIO . atomically $ do
-          case sta' of
+          case res of
               Nothing -> return ()
-              Just sta -> do
+              Just (sta, s') -> do
                 putTMVar stateRef s'
                 case sta of
                     MessageS  m -> do writeTChan messageC $ Right m