packages feed

extensible-effects-concurrent 0.12.1 → 0.13.0

raw patch · 6 files changed

+17/−11 lines, 6 filesPVP ok

version bump matches the API change (PVP)

API changes (from Hackage documentation)

- Control.Eff.Concurrent: callCallback :: forall api_a18DC eff_a18DD reply_a18DG. Getter (ApiHandler api_a18DC eff_a18DD) (Maybe (Api api_a18DC ( 'Synchronous reply_a18DG) -> (reply_a18DG -> Eff eff_a18DD ()) -> Eff eff_a18DD ApiServerCmd))
+ Control.Eff.Concurrent: callCallback :: forall api_a18oA eff_a18oB reply_a18oE. Getter (ApiHandler api_a18oA eff_a18oB) (Maybe (Api api_a18oA ( 'Synchronous reply_a18oE) -> (reply_a18oE -> Eff eff_a18oB ()) -> Eff eff_a18oB ApiServerCmd))
- Control.Eff.Concurrent: castCallback :: forall api_a18DC eff_a18DD. Lens' (ApiHandler api_a18DC eff_a18DD) (Maybe (Api api_a18DC 'Asynchronous -> Eff eff_a18DD ApiServerCmd))
+ Control.Eff.Concurrent: castCallback :: forall api_a18oA eff_a18oB. Lens' (ApiHandler api_a18oA eff_a18oB) (Maybe (Api api_a18oA 'Asynchronous -> Eff eff_a18oB ApiServerCmd))
- Control.Eff.Concurrent: enqueueObservations :: forall o r q a. (SetMember Process (Process q) r, Typeable o, Show (Observation o), Observable o, HasLogging IO r, HasLogging IO q, Member Interrupts r, Member Interrupts q, Lifted IO q, HasCallStack, MonadCatch (Eff r)) => SchedulerProxy q -> Server o -> Int -> Eff (ObservationQueueReader o : r) a -> Eff r a
+ Control.Eff.Concurrent: enqueueObservations :: forall o r q a. (SetMember Process (Process q) r, Typeable o, Show (Observation o), Observable o, HasLogging IO r, HasLogging IO q, Member Interrupts r, Lifted IO q, HasCallStack, MonadCatch (Eff r)) => SchedulerProxy q -> Server o -> Int -> Eff (ObservationQueueReader o : r) a -> Eff r a
- Control.Eff.Concurrent: enqueueObservationsRegistered :: forall o r q a. (ServesApi o r q, SetMember Process (Process q) r, Typeable o, Show (Observation o), Observable o, HasLogging IO q, HasLogging IO r, Member Interrupts q, Member Interrupts r, Lifted IO r, HasCallStack, MonadCatch (Eff r)) => SchedulerProxy q -> Int -> Eff (ObservationQueueReader o : r) a -> Eff r a
+ Control.Eff.Concurrent: enqueueObservationsRegistered :: forall o r q a. (ServesApi o r q, SetMember Process (Process q) r, Typeable o, Show (Observation o), Observable o, HasLogging IO q, HasLogging IO r, Member Interrupts r, Lifted IO r, HasCallStack, MonadCatch (Eff r)) => SchedulerProxy q -> Int -> Eff (ObservationQueueReader o : r) a -> Eff r a
- Control.Eff.Concurrent: fromServer :: forall api_a17Zf api_a189x. Iso (Server api_a17Zf) (Server api_a189x) ProcessId ProcessId
+ Control.Eff.Concurrent: fromServer :: forall api_a17Kd api_a17Uv. Iso (Server api_a17Kd) (Server api_a17Uv) ProcessId ProcessId
- Control.Eff.Concurrent: requestHandlerSelector :: forall eff_a18PS. Lens' (ServerCallback eff_a18PS) (MessageSelector (Eff eff_a18PS ApiServerCmd))
+ Control.Eff.Concurrent: requestHandlerSelector :: forall eff_a18AQ. Lens' (ServerCallback eff_a18AQ) (MessageSelector (Eff eff_a18AQ ApiServerCmd))
- Control.Eff.Concurrent: terminateCallback :: forall api_a18DC eff_a18DD. Lens' (ApiHandler api_a18DC eff_a18DD) (Maybe (ExitReason 'Recoverable -> Eff eff_a18DD ()))
+ Control.Eff.Concurrent: terminateCallback :: forall api_a18oA eff_a18oB. Lens' (ApiHandler api_a18oA eff_a18oB) (Maybe (ExitReason 'Recoverable -> Eff eff_a18oB ()))
- Control.Eff.Concurrent: terminationHandler :: forall eff_a18PS. Lens' (ServerCallback eff_a18PS) (ExitReason 'Recoverable -> Eff eff_a18PS ())
+ Control.Eff.Concurrent: terminationHandler :: forall eff_a18AQ. Lens' (ServerCallback eff_a18AQ) (ExitReason 'Recoverable -> Eff eff_a18AQ ())
- Control.Eff.Concurrent: unhandledCallError :: forall p x r q. (Typeable p, HasCallStack, SetMember Process (Process q) r, Member (Exc (ExitReason 'Recoverable)) r) => SchedulerProxy q -> Api p ( 'Synchronous x) -> (x -> Eff r ()) -> Eff r ApiServerCmd
+ Control.Eff.Concurrent: unhandledCallError :: forall p x r q. (Typeable p, HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => SchedulerProxy q -> Api p ( 'Synchronous x) -> (x -> Eff r ()) -> Eff r ApiServerCmd
- Control.Eff.Concurrent: unhandledCastError :: forall p r q. (Typeable p, HasCallStack, SetMember Process (Process q) r, Member (Exc (ExitReason 'Recoverable)) r) => SchedulerProxy q -> Api p 'Asynchronous -> Eff r ApiServerCmd
+ Control.Eff.Concurrent: unhandledCastError :: forall p r q. (Typeable p, HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => SchedulerProxy q -> Api p 'Asynchronous -> Eff r ApiServerCmd
- Control.Eff.Concurrent.Api: fromServer :: forall api_a17Zf api_a189x. Iso (Server api_a17Zf) (Server api_a189x) ProcessId ProcessId
+ Control.Eff.Concurrent.Api: fromServer :: forall api_a17Kd api_a17Uv. Iso (Server api_a17Kd) (Server api_a17Uv) ProcessId ProcessId
- Control.Eff.Concurrent.Api.Observer.Queue: enqueueObservations :: forall o r q a. (SetMember Process (Process q) r, Typeable o, Show (Observation o), Observable o, HasLogging IO r, HasLogging IO q, Member Interrupts r, Member Interrupts q, Lifted IO q, HasCallStack, MonadCatch (Eff r)) => SchedulerProxy q -> Server o -> Int -> Eff (ObservationQueueReader o : r) a -> Eff r a
+ Control.Eff.Concurrent.Api.Observer.Queue: enqueueObservations :: forall o r q a. (SetMember Process (Process q) r, Typeable o, Show (Observation o), Observable o, HasLogging IO r, HasLogging IO q, Member Interrupts r, Lifted IO q, HasCallStack, MonadCatch (Eff r)) => SchedulerProxy q -> Server o -> Int -> Eff (ObservationQueueReader o : r) a -> Eff r a
- Control.Eff.Concurrent.Api.Observer.Queue: enqueueObservationsRegistered :: forall o r q a. (ServesApi o r q, SetMember Process (Process q) r, Typeable o, Show (Observation o), Observable o, HasLogging IO q, HasLogging IO r, Member Interrupts q, Member Interrupts r, Lifted IO r, HasCallStack, MonadCatch (Eff r)) => SchedulerProxy q -> Int -> Eff (ObservationQueueReader o : r) a -> Eff r a
+ Control.Eff.Concurrent.Api.Observer.Queue: enqueueObservationsRegistered :: forall o r q a. (ServesApi o r q, SetMember Process (Process q) r, Typeable o, Show (Observation o), Observable o, HasLogging IO q, HasLogging IO r, Member Interrupts r, Lifted IO r, HasCallStack, MonadCatch (Eff r)) => SchedulerProxy q -> Int -> Eff (ObservationQueueReader o : r) a -> Eff r a
- Control.Eff.Concurrent.Api.Server: callCallback :: forall api_a18DC eff_a18DD reply_a18DG. Getter (ApiHandler api_a18DC eff_a18DD) (Maybe (Api api_a18DC ( 'Synchronous reply_a18DG) -> (reply_a18DG -> Eff eff_a18DD ()) -> Eff eff_a18DD ApiServerCmd))
+ Control.Eff.Concurrent.Api.Server: callCallback :: forall api_a18oA eff_a18oB reply_a18oE. Getter (ApiHandler api_a18oA eff_a18oB) (Maybe (Api api_a18oA ( 'Synchronous reply_a18oE) -> (reply_a18oE -> Eff eff_a18oB ()) -> Eff eff_a18oB ApiServerCmd))
- Control.Eff.Concurrent.Api.Server: castCallback :: forall api_a18DC eff_a18DD. Lens' (ApiHandler api_a18DC eff_a18DD) (Maybe (Api api_a18DC 'Asynchronous -> Eff eff_a18DD ApiServerCmd))
+ Control.Eff.Concurrent.Api.Server: castCallback :: forall api_a18oA eff_a18oB. Lens' (ApiHandler api_a18oA eff_a18oB) (Maybe (Api api_a18oA 'Asynchronous -> Eff eff_a18oB ApiServerCmd))
- Control.Eff.Concurrent.Api.Server: requestHandlerSelector :: forall eff_a18PS. Lens' (ServerCallback eff_a18PS) (MessageSelector (Eff eff_a18PS ApiServerCmd))
+ Control.Eff.Concurrent.Api.Server: requestHandlerSelector :: forall eff_a18AQ. Lens' (ServerCallback eff_a18AQ) (MessageSelector (Eff eff_a18AQ ApiServerCmd))
- Control.Eff.Concurrent.Api.Server: terminateCallback :: forall api_a18DC eff_a18DD. Lens' (ApiHandler api_a18DC eff_a18DD) (Maybe (ExitReason 'Recoverable -> Eff eff_a18DD ()))
+ Control.Eff.Concurrent.Api.Server: terminateCallback :: forall api_a18oA eff_a18oB. Lens' (ApiHandler api_a18oA eff_a18oB) (Maybe (ExitReason 'Recoverable -> Eff eff_a18oB ()))
- Control.Eff.Concurrent.Api.Server: terminationHandler :: forall eff_a18PS. Lens' (ServerCallback eff_a18PS) (ExitReason 'Recoverable -> Eff eff_a18PS ())
+ Control.Eff.Concurrent.Api.Server: terminationHandler :: forall eff_a18AQ. Lens' (ServerCallback eff_a18AQ) (ExitReason 'Recoverable -> Eff eff_a18AQ ())
- Control.Eff.Concurrent.Api.Server: unhandledCallError :: forall p x r q. (Typeable p, HasCallStack, SetMember Process (Process q) r, Member (Exc (ExitReason 'Recoverable)) r) => SchedulerProxy q -> Api p ( 'Synchronous x) -> (x -> Eff r ()) -> Eff r ApiServerCmd
+ Control.Eff.Concurrent.Api.Server: unhandledCallError :: forall p x r q. (Typeable p, HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => SchedulerProxy q -> Api p ( 'Synchronous x) -> (x -> Eff r ()) -> Eff r ApiServerCmd
- Control.Eff.Concurrent.Api.Server: unhandledCastError :: forall p r q. (Typeable p, HasCallStack, SetMember Process (Process q) r, Member (Exc (ExitReason 'Recoverable)) r) => SchedulerProxy q -> Api p 'Asynchronous -> Eff r ApiServerCmd
+ Control.Eff.Concurrent.Api.Server: unhandledCastError :: forall p r q. (Typeable p, HasCallStack, SetMember Process (Process q) r, Member Interrupts r) => SchedulerProxy q -> Api p 'Asynchronous -> Eff r ApiServerCmd

Files

ChangeLog.md view
@@ -1,5 +1,13 @@ # Changelog for extensible-effects-concurrent +## 0.13.0++- Fix bad constraints in `Queue` observer++## 0.12.2++- Fix some compiler warnings+ ## 0.12.1  - Fix build errors with GHC-8.6
examples/example-3/Main.hs view
@@ -10,7 +10,7 @@  main :: IO () main = withAsyncLogChannel-  1000+  (1000 :: Int)   (ioLogMessageWriter     (fileAppender "extensible-effects-concurrent-example-3.log")   )
extensible-effects-concurrent.cabal view
@@ -1,5 +1,5 @@ name:           extensible-effects-concurrent-version:        0.12.1+version:        0.13.0 description:    Please see the README on GitHub at <https://github.com/sheyll/extensible-effects-concurrent#readme> synopsis:       Message passing concurrency as extensible-effect homepage:       https://github.com/sheyll/extensible-effects-concurrent#readme
src/Control/Eff/Concurrent/Api/Observer/Queue.hs view
@@ -99,7 +99,6 @@      , Observable o      , HasLogging IO q      , HasLogging IO r-     , Member Interrupts q      , Member Interrupts r      , Lifted IO r      , HasCallStack@@ -128,7 +127,6 @@      , HasLogging IO r      , HasLogging IO q      , Member Interrupts r-     , Member Interrupts q      , Lifted IO q      , HasCallStack      , MonadCatch (Eff r)
src/Control/Eff/Concurrent/Api/Server.hs view
@@ -341,13 +341,13 @@    . ( HasCallStack      , Typeable api      , SetMember Process (Process effScheduler) eff-     , Member (Exc (ExitReason 'Recoverable)) eff+     , Member Interrupts eff      )   => SchedulerProxy effScheduler   -> ApiHandler api eff   -> MessageSelector (Eff eff ApiServerCmd)-selectHandlerMethod px handlers = selectDynamicMessageLazy-  (fmap (applyHandlerMethod px handlers) . fromDynamic)+selectHandlerMethod px handlers =+  selectDynamicMessageLazy (fmap (applyHandlerMethod px handlers) . fromDynamic)  -- | Apply either the '_callCallback', '_castCallback' or the '_terminateCallback' -- callback to an incoming request.@@ -355,7 +355,7 @@   :: forall eff effScheduler api    . ( Typeable api      , SetMember Process (Process effScheduler) eff-     , Member (Exc (ExitReason 'Recoverable)) eff+     , Member Interrupts eff      , HasCallStack      )   => SchedulerProxy effScheduler@@ -381,7 +381,7 @@    . ( Typeable p      , HasCallStack      , SetMember Process (Process q) r-     , Member (Exc (ExitReason 'Recoverable)) r+     , Member Interrupts r      )   => SchedulerProxy q   -> Api p ( 'Synchronous x)@@ -397,7 +397,7 @@    . ( Typeable p      , HasCallStack      , SetMember Process (Process q) r-     , Member (Exc (ExitReason 'Recoverable)) r+     , Member Interrupts r      )   => SchedulerProxy q   -> Api p 'Asynchronous
src/Control/Eff/Concurrent/Process/ForkIOScheduler.hs view
@@ -237,7 +237,7 @@ -- top of 'SchedulerIO' effect. All logging is sent to standard output. defaultMain :: HasCallStack => Eff InterruptableProcEff () -> IO () defaultMain c =-  withAsyncLogChannel 1024+  withAsyncLogChannel (1024 :: Int)     (multiMessageLogWriter ($ printLogMessage))     (handleLoggingAndIO_ (schedule c))