serverOut
(listenServer serverMsgs requestMap reqSema rspSema passSema mainThread)
def
+ fullCaps
sessionDir
(sendMessages clientMsgs reqSema rspSema)
takeMVar passSema
then listenServer (delete msg expectedMsgs) reqMap reqSema rspSema passSema mainThreadId serverOut ctx
else let remainingMsgs = takeWhile (not . isNotification) expectedMsgs
++ [head $ dropWhile isNotification expectedMsgs]
- exc = ReplayOutOfOrderException msg remainingMsgs
+ exc = ReplayOutOfOrder msg remainingMsgs
in liftIO $ throwTo mainThreadId exc
where