net-mqtt 0.8.7.1 → 0.8.7.2

raw patch · 2 files changed

+6/−5 lines, 2 filesPVP ok

version bump matches the API change (PVP)

API changes (from Hackage documentation)

Files

• net-mqtt.cabal +1/−1
• src/Network/MQTT/Client.hs +5/−4

@@ -5,7 +5,7 @@ -- see: https://github.com/sol/hpack  name:           net-mqtt-version:        0.8.7.1+version:        0.8.7.2 synopsis:       An MQTT Protocol Implementation. description:    Please see the README on GitHub at <https://github.com/dustin/mqtt-hs#readme> category:       Network

@@ -338,10 +338,11 @@     clientThread cli = E.finally connectAndRun markDisco       where         connectAndRun = mkconn $ \ad -> start cli ad >>= run ad-        markDisco = atomically $ do-          st <- readTVar (_st cli)-          guard $ st == Starting || st == Connected-          writeTVar (_st cli) Disconnected+        markDisco = atomically $+          modifyTVar' (_st cli) $ \case+            Starting -> Disconnected+            Connected -> Disconnected+            x -> x      start c (_,sink) = do       void . runConduit $ do