polysemy-conc 0.12.0.0 → 0.12.1.0

raw patch · 17 files changed

+34/−43 lines, 17 filesdep ~incipit-corePVP ok

version bump matches the API change (PVP)

Dependency ranges changed: incipit-core

API changes (from Hackage documentation)

Files

• lib/Polysemy/Conc.hs +28/−20
• lib/Polysemy/Conc/Async.hs +0/−1
• lib/Polysemy/Conc/Effect/Events.hs +0/−2
• lib/Polysemy/Conc/Effect/Gate.hs +0/−2
• lib/Polysemy/Conc/Effect/Mask.hs +0/−2
• lib/Polysemy/Conc/Effect/Monitor.hs +0/−1
• lib/Polysemy/Conc/Effect/Scoped.hs +2/−0
• lib/Polysemy/Conc/Effect/Sync.hs +0/−2
• lib/Polysemy/Conc/Events.hs +0/−1
• lib/Polysemy/Conc/Interpreter/Events.hs +0/−2
• lib/Polysemy/Conc/Interpreter/Gate.hs +0/−2
• lib/Polysemy/Conc/Interpreter/Mask.hs +0/−1
• lib/Polysemy/Conc/Interpreter/Monitor.hs +0/−1
• lib/Polysemy/Conc/Interpreter/Scoped.hs +1/−0
• lib/Polysemy/Conc/Interpreter/Sync.hs +0/−2
• lib/Polysemy/Conc/Sync.hs +0/−1
• polysemy-conc.cabal +3/−3

@@ -201,6 +201,23 @@   withAsyncGated_, ) where +import Prelude hiding (+  Scoped,+  Scoped_,+  interpretScoped,+  interpretScopedAs,+  interpretScopedH,+  interpretScopedH',+  interpretScopedWith,+  interpretScopedWithH,+  interpretScopedWith_,+  rescope,+  runScoped,+  runScopedAs,+  scoped,+  scoped_,+  )+ import Polysemy.Conc.Async (   scheduleAsync,   scheduleAsyncIO,@@ -217,26 +234,11 @@ import Polysemy.Conc.Effect.Gate (Gate, Gates) import Polysemy.Conc.Effect.Interrupt (Interrupt) import Polysemy.Conc.Effect.Lock (Lock, lock, lockOr, lockOrSkip, lockOrSkip_)-import Polysemy.Conc.Effect.Mask (-  Mask,-  Restoration,-  UninterruptibleMask,-  mask,-  restore,-  uninterruptibleMask,-  )-import Polysemy.Conc.Effect.Monitor (-  Monitor,-  Restart,-  RestartingMonitor,-  ScopedMonitor,-  monitor,-  restart,-  withMonitor,-  )+import Polysemy.Conc.Effect.Mask (Mask, Restoration, UninterruptibleMask, mask, restore, uninterruptibleMask)+import Polysemy.Conc.Effect.Monitor (Monitor, Restart, RestartingMonitor, ScopedMonitor, monitor, restart, withMonitor) import Polysemy.Conc.Effect.Queue (Queue) import Polysemy.Conc.Effect.Race (Race, race, timeout)-import Polysemy.Conc.Effect.Scoped (Scoped, Scoped_, scoped, scoped_, rescope)+import Polysemy.Conc.Effect.Scoped (Scoped, Scoped_, rescope, scoped, scoped_) import Polysemy.Conc.Effect.Semaphore (Semaphore) import Polysemy.Conc.Effect.Sync (ScopedSync, Sync) import Polysemy.Conc.Effect.SyncRead (SyncRead)@@ -263,7 +265,12 @@ import Polysemy.Conc.Interpreter.Gate (interpretGate, interpretGates) import Polysemy.Conc.Interpreter.Interrupt (interpretInterrupt, interpretInterruptNull, interpretInterruptOnce) import Polysemy.Conc.Interpreter.Lock (interpretLockPermissive, interpretLockReentrant)-import Polysemy.Conc.Interpreter.Mask (interpretMaskFinal, interpretMaskPure, interpretUninterruptibleMaskFinal, interpretUninterruptibleMaskPure)+import Polysemy.Conc.Interpreter.Mask (+  interpretMaskFinal,+  interpretMaskPure,+  interpretUninterruptibleMaskFinal,+  interpretUninterruptibleMaskPure,+  ) import Polysemy.Conc.Interpreter.Monitor (interpretMonitorPure, interpretMonitorRestart) import Polysemy.Conc.Interpreter.Queue.Pure (   interpretQueueListReadOnlyAtomic,@@ -284,6 +291,7 @@   interpretScoped,   interpretScopedAs,   interpretScopedH,+  interpretScopedH',   interpretScopedR,   interpretScopedRH,   interpretScopedRWith,@@ -300,7 +308,7 @@   interpretScopedWithH,   interpretScopedWith_,   runScoped,-  runScopedAs, interpretScopedH',+  runScopedAs,   ) import Polysemy.Conc.Interpreter.Semaphore (interpretSemaphoreQ, interpretSemaphoreT) import Polysemy.Conc.Interpreter.Stack (ConcStack, runConc)

@@ -6,7 +6,6 @@  import Polysemy.Conc.Effect.Gate (Gate, gate, withGate) import Polysemy.Conc.Effect.Race (Race)-import Polysemy.Scoped (Scoped_) import qualified Polysemy.Conc.Effect.Sync as Sync import Polysemy.Conc.Effect.Sync (ScopedSync, Sync) import Polysemy.Conc.Interpreter.Sync (interpretSync)

@@ -3,8 +3,6 @@ -- |Description: Events/Consume Effects, Internal module Polysemy.Conc.Effect.Events where -import Polysemy.Scoped (Scoped_, scoped_)- -- |An event publisher that can be consumed from multiple threads. data Events (e :: Type) :: Effect where   Publish :: e -> Events e m ()

@@ -3,8 +3,6 @@ -- |Description: Gate effect, Internal module Polysemy.Conc.Effect.Gate where -import Polysemy.Scoped (Scoped_, scoped_)- -- |A single-use synchronization point that blocks all consumers who called 'gate' until 'signal' is called. -- -- The constructors are exported from [Polysemy.Conc.Gate]("Polysemy.Conc.Gate").

@@ -3,8 +3,6 @@ -- |Description: Mask Effect, Internal module Polysemy.Conc.Effect.Mask where -import Polysemy.Scoped (Scoped_, scoped_)- -- |Part of an effect abstracting 'Control.Exception.mask'. data RestoreMask :: Effect where   Restore :: m a -> RestoreMask m a

@@ -3,7 +3,6 @@ -- |Description: Monitor Effect, Internal module Polysemy.Conc.Effect.Monitor where -import Polysemy.Scoped (Scoped_, scoped_) import Polysemy.Time (NanoSeconds)  -- |Marker type for the restarting action for 'Monitor'.

@@ -3,6 +3,8 @@ -- |Description: Scoped Effect, Internal module Polysemy.Conc.Effect.Scoped where +import Prelude hiding (Scoped, Scoped_, scoped)+ -- | @Scoped@ transforms a program so that an interpreter for @effect@ may -- perform arbitrary actions, like resource management, before and after the -- computation wrapped by a call to 'scoped' is executed.

@@ -6,8 +6,6 @@ import Polysemy.Time (TimeUnit) import Prelude hiding (empty, try) -import Polysemy.Scoped (Scoped_)- -- |Abstracts an 'Control.Concurrent.MVar'. -- -- For documentation on the constructors, see the module "Polysemy.Conc.Effect.Sync".

@@ -6,7 +6,6 @@ import Polysemy.Conc.Effect.Events (Consume) import Polysemy.Conc.Effect.Gate (Gate, Gates, gate, signal, withGate) import Polysemy.Conc.Effect.Race (Race)-import Polysemy.Scoped (Scoped_) import Polysemy.Conc.Interpreter.Events (EventConsumer)  -- |Create a new scope for 'Polysemy.Conc.Events', causing the nested program to get its own copy of the event stream.

@@ -9,8 +9,6 @@ import qualified Polysemy.Conc.Effect.Events as Events import Polysemy.Conc.Effect.Events (Consume, Events) import Polysemy.Conc.Effect.Race (Race)-import Polysemy.Scoped (Scoped_)-import Polysemy.Scoped (runScopedAs)  -- |Convenience alias for the consumer effect. type EventConsumer e =

@@ -2,8 +2,6 @@ module Polysemy.Conc.Interpreter.Gate where  import Polysemy.Conc.Effect.Gate (Gate (Gate, Signal))-import Polysemy.Scoped (Scoped_)-import Polysemy.Scoped (interpretScopedAs)  -- |Interpret 'Gate' with an 'MVar'. interpretGate ::

@@ -12,7 +12,6 @@   RestoreMask (Restore),   UninterruptibleMask,   )-import Polysemy.Scoped (interpretScopedH, runScoped)  mask ::   Member (Final IO) r =>

@@ -4,7 +4,6 @@ module Polysemy.Conc.Interpreter.Monitor where  import qualified Control.Exception as Base-import Polysemy.Scoped (interpretScopedH, runScopedAs) import qualified Polysemy.Time as Time import Polysemy.Time (Time) 

@@ -20,6 +20,7 @@ import Polysemy.Membership (ElemOf) import Polysemy.Resume (Stop, interpretResumableH, runStop, type (!!)) import Polysemy.Resume.Effect.Resumable (Resumable (Resumable))+import Prelude hiding (Scoped, interpretScoped, interpretScopedH, interpretScopedWithH, runScoped)  import Polysemy.Conc.Effect.Scoped (Scoped (InScope, Run)) 

@@ -2,10 +2,8 @@ module Polysemy.Conc.Interpreter.Sync where  import Polysemy.Conc.Effect.Race (Race)-import Polysemy.Scoped (Scoped_) import qualified Polysemy.Conc.Effect.Sync as Sync import Polysemy.Conc.Effect.Sync (Sync)-import Polysemy.Scoped (runScopedAs) import qualified Polysemy.Conc.Race as Race  -- |Interpret 'Sync' with the provided 'MVar'.

@@ -10,7 +10,6 @@ import Polysemy.Time (Time, TimeUnit)  import Polysemy.Conc.Effect.Mask (Mask, mask, restore)-import Polysemy.Scoped (scoped_) import qualified Polysemy.Conc.Effect.Sync as Sync import Polysemy.Conc.Effect.Sync 

@@ -5,7 +5,7 @@ -- see: https://github.com/sol/hpack  name:           polysemy-conc-version:        0.12.0.0+version:        0.12.1.0 synopsis:       Polysemy effects for concurrency description:    See https://hackage.haskell.org/package/polysemy-conc/docs/Polysemy-Conc.html category:       Concurrency@@ -140,7 +140,7 @@       async     , base >=4.12 && <5     , containers-    , incipit-core >=0.4+    , incipit-core >=0.4.1     , polysemy ==1.9.*     , polysemy-resume ==0.7.*     , polysemy-time ==0.6.*@@ -235,7 +235,7 @@       async     , base >=4.12 && <5     , hedgehog-    , incipit-core >=0.4+    , incipit-core >=0.4.1     , polysemy     , polysemy-conc     , polysemy-plugin