polysemy-conc 0.7.0.0 → 0.8.0.0
raw patch · 3 files changed
+6/−5 lines, 3 filesPVP ok
version bump matches the API change (PVP)
API changes (from Hackage documentation)
+ Polysemy.Conc: data Consume (e :: Type) :: Effect
Files
- lib/Polysemy/Conc.hs +4/−3
- lib/Polysemy/Conc/AtomicState.hs +1/−1
- polysemy-conc.cabal +1/−1
lib/Polysemy/Conc.hs view
@@ -64,6 +64,7 @@ -- * Event Channels Events,+ Consume, publish, consume, subscribe,@@ -147,7 +148,7 @@ import Polysemy.Conc.AtomicState (interpretAtomic) import Polysemy.Conc.Data.QueueResult (QueueResult) import Polysemy.Conc.Effect.Critical (Critical)-import Polysemy.Conc.Effect.Events (EventResource, Events, consume, publish, subscribe)+import Polysemy.Conc.Effect.Events (Consume, EventResource, Events, consume, publish, subscribe) import Polysemy.Conc.Effect.Interrupt (Interrupt) import Polysemy.Conc.Effect.Mask (Mask, UninterruptibleMask, mask, restore, uninterruptibleMask) import Polysemy.Conc.Effect.Monitor (@@ -164,6 +165,7 @@ import Polysemy.Conc.Effect.Race (Race, race, timeout) import Polysemy.Conc.Effect.Scoped (Scoped, scoped) import Polysemy.Conc.Effect.Sync (ScopedSync, Sync)+import Polysemy.Conc.Effect.SyncRead (SyncRead) import Polysemy.Conc.Events (subscribeLoop, subscribeWhile) import Polysemy.Conc.Interpreter.Critical (interpretCritical, interpretCriticalNull) import Polysemy.Conc.Interpreter.Events (ChanConsumer, ChanEvents, EventChan, EventConsumer, interpretEventsChan)@@ -190,14 +192,13 @@ ) import Polysemy.Conc.Interpreter.Stack (ConcStack, runConc) import Polysemy.Conc.Interpreter.Sync (interpretScopedSync, interpretScopedSyncAs, interpretSync, interpretSyncAs)+import Polysemy.Conc.Interpreter.SyncRead (syncRead) import Polysemy.Conc.Monitor (ClockSkewConfig (ClockSkewConfig), clockSkewConfig, monitorClockSkew) import Polysemy.Conc.Queue (loop, loopOr) import Polysemy.Conc.Queue.Result (resultToMaybe) import Polysemy.Conc.Race (race_, timeoutAs, timeoutAs_, timeoutMaybe, timeoutU, timeout_) import Polysemy.Conc.Retry (retrying, retryingWithError) import Polysemy.Conc.Sync (lock, withSync)-import Polysemy.Conc.Effect.SyncRead (SyncRead)-import Polysemy.Conc.Interpreter.SyncRead (syncRead) -- $intro -- This library provides an assortment of tools for concurrency-related tasks:
lib/Polysemy/Conc/AtomicState.hs view
@@ -3,7 +3,7 @@ import Control.Concurrent.STM (newTVarIO) --- |Convenience wrapper around 'runAtomicStateTVar' that creates a new 'TVar'.+-- |Convenience wrapper around 'runAtomicStateTVar' that creates a new 'Control.Concurrent.STM.TVar'. interpretAtomic :: ∀ a r . Member (Embed IO) r =>
polysemy-conc.cabal view
@@ -5,7 +5,7 @@ -- see: https://github.com/sol/hpack name: polysemy-conc-version: 0.7.0.0+version: 0.8.0.0 synopsis: Polysemy Effects for Concurrency description: See <https://hackage.haskell.org/package/polysemy-conc/docs/Polysemy-Conc.html> category: Concurrency