nqe 0.6.6 → 0.6.7

raw patch · 3 files changed

+10/−5 lines, 3 filesPVP ok

version bump matches the API change (PVP)

API changes (from Hackage documentation)

Files

CHANGELOG.md +4/−0
nqe.cabal +2/−4
src/Control/Concurrent/NQE/Publisher.hs +4/−1

CHANGELOG.md view

@@ -4,6 +4,10 @@ The format is based on [Keep a Changelog](http://keepachangelog.com/en/1.0.0/) and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.html). +## 0.6.7+### Changed+- Use `>>=` explicitly to avoid problems with the LoggingT monad.+ ## 0.6.6 ### Changed - Simplify author name.

nqe.cabal view

@@ -1,13 +1,11 @@ cabal-version: 1.12 --- This file has been generated from package.yaml by hpack version 0.38.0.+-- This file has been generated from package.yaml by hpack version 0.39.6. -- -- see: https://github.com/sol/hpack------ hash: eccc612cfd9271d97bc20072fbd9bda9b4353231324881cd805cd2cf55df53e1  name:           nqe-version:        0.6.6+version:        0.6.7 synopsis:       Concurrency library in the style of Erlang/OTP description:    Please see the README on GitHub at <https://github.com/jprupp/nqe#readme> category:       Control

src/Control/Concurrent/NQE/Publisher.hs view

@@ -98,7 +98,10 @@ publisherProcess :: MonadUnliftIO m => Inbox (PublisherMessage msg) -> m () publisherProcess inbox = newTVarIO [] >>= runReaderT go   where-    go = forever $ receive inbox >>= publisherMessage+    -- Sequenced with (>>=) only: 'forever' uses (*>), which for a monad+    -- that is only known through its dictionary (LoggingT in particular)+    -- leaves a continuation frame and two thunks per message, forever.+    go = receive inbox >>= publisherMessage >>= \_ -> go  -- | Internal function to dispatch a publisher message. publisherMessage ::