distributed-process-client-server 0.2.7.0 → 0.2.7.1
raw patch · 2 files changed
+6/−2 lines, 2 filesdep ~ansi-terminalnew-uploaderPVP: major bump suggested
API removals or changes: PVP suggests a major version bump
Dependency ranges changed: ansi-terminal
API changes (from Hackage documentation)
- Control.Distributed.Process.ManagedProcess: act :: forall s. GenProcess s () -> Action s
+ Control.Distributed.Process.ManagedProcess: act :: GenProcess s () -> Action s
- Control.Distributed.Process.ManagedProcess: push :: forall s. Message -> GenProcess s ()
+ Control.Distributed.Process.ManagedProcess: push :: Message -> GenProcess s ()
- Control.Distributed.Process.ManagedProcess: type Action s = Process (ProcessAction s)
+ Control.Distributed.Process.ManagedProcess: type Action s = Process ProcessAction s
- Control.Distributed.Process.ManagedProcess: type InitHandler a s = a -> Process (InitResult s)
+ Control.Distributed.Process.ManagedProcess: type InitHandler a s = a -> Process InitResult s
- Control.Distributed.Process.ManagedProcess: type Reply b s = Process (ProcessReply b s)
+ Control.Distributed.Process.ManagedProcess: type Reply b s = Process ProcessReply b s
- Control.Distributed.Process.ManagedProcess: type StatelessHandler s a = a -> (s -> Action s)
+ Control.Distributed.Process.ManagedProcess: type StatelessHandler s a = a -> s -> Action s
- Control.Distributed.Process.ManagedProcess.Client: call :: forall s a b. (Addressable s, Serializable a, Serializable b) => s -> a -> Process b
+ Control.Distributed.Process.ManagedProcess.Client: call :: (Addressable s, Serializable a, Serializable b) => s -> a -> Process b
- Control.Distributed.Process.ManagedProcess.Client: callAsync :: forall s a b. (Addressable s, Serializable a, Serializable b) => s -> a -> Process (Async b)
+ Control.Distributed.Process.ManagedProcess.Client: callAsync :: (Addressable s, Serializable a, Serializable b) => s -> a -> Process (Async b)
- Control.Distributed.Process.ManagedProcess.Client: callChan :: forall s a b. (Addressable s, Serializable a, Serializable b) => s -> a -> Process (ReceivePort b)
+ Control.Distributed.Process.ManagedProcess.Client: callChan :: (Addressable s, Serializable a, Serializable b) => s -> a -> Process (ReceivePort b)
- Control.Distributed.Process.ManagedProcess.Client: callSTM :: forall s a b. Addressable s => s -> (a -> STM ()) -> STM b -> a -> Process (Either ExitReason b)
+ Control.Distributed.Process.ManagedProcess.Client: callSTM :: Addressable s => s -> (a -> STM ()) -> STM b -> a -> Process (Either ExitReason b)
- Control.Distributed.Process.ManagedProcess.Client: callTimeout :: forall s a b. (Addressable s, Serializable a, Serializable b) => s -> a -> TimeInterval -> Process (Maybe b)
+ Control.Distributed.Process.ManagedProcess.Client: callTimeout :: (Addressable s, Serializable a, Serializable b) => s -> a -> TimeInterval -> Process (Maybe b)
- Control.Distributed.Process.ManagedProcess.Client: cast :: forall a m. (Addressable a, Serializable m) => a -> m -> Process ()
+ Control.Distributed.Process.ManagedProcess.Client: cast :: (Addressable a, Serializable m) => a -> m -> Process ()
- Control.Distributed.Process.ManagedProcess.Client: flushPendingCalls :: forall b. Serializable b => TimeInterval -> (b -> Process b) -> Process (Maybe b)
+ Control.Distributed.Process.ManagedProcess.Client: flushPendingCalls :: Serializable b => TimeInterval -> (b -> Process b) -> Process (Maybe b)
- Control.Distributed.Process.ManagedProcess.Client: safeCall :: forall s a b. (Addressable s, Serializable a, Serializable b) => s -> a -> Process (Either ExitReason b)
+ Control.Distributed.Process.ManagedProcess.Client: safeCall :: (Addressable s, Serializable a, Serializable b) => s -> a -> Process (Either ExitReason b)
- Control.Distributed.Process.ManagedProcess.Client: syncCallChan :: forall s a b. (Addressable s, Serializable a, Serializable b) => s -> a -> Process b
+ Control.Distributed.Process.ManagedProcess.Client: syncCallChan :: (Addressable s, Serializable a, Serializable b) => s -> a -> Process b
- Control.Distributed.Process.ManagedProcess.Client: syncSafeCallChan :: forall s a b. (Addressable s, Serializable a, Serializable b) => s -> a -> Process (Either ExitReason b)
+ Control.Distributed.Process.ManagedProcess.Client: syncSafeCallChan :: (Addressable s, Serializable a, Serializable b) => s -> a -> Process (Either ExitReason b)
- Control.Distributed.Process.ManagedProcess.Client: tryCall :: forall s a b. (Addressable s, Serializable a, Serializable b) => s -> a -> Process (Maybe b)
+ Control.Distributed.Process.ManagedProcess.Client: tryCall :: (Addressable s, Serializable a, Serializable b) => s -> a -> Process (Maybe b)
- Control.Distributed.Process.ManagedProcess.Internal.GenProcess: act :: forall s. GenProcess s () -> Action s
+ Control.Distributed.Process.ManagedProcess.Internal.GenProcess: act :: GenProcess s () -> Action s
- Control.Distributed.Process.ManagedProcess.Internal.GenProcess: enqueue :: forall s. Message -> GenProcess s ()
+ Control.Distributed.Process.ManagedProcess.Internal.GenProcess: enqueue :: Message -> GenProcess s ()
- Control.Distributed.Process.ManagedProcess.Internal.GenProcess: eval :: forall s. GenProcess s (ProcessAction s) -> Action s
+ Control.Distributed.Process.ManagedProcess.Internal.GenProcess: eval :: GenProcess s (ProcessAction s) -> Action s
- Control.Distributed.Process.ManagedProcess.Internal.GenProcess: gets :: forall s a. (ProcessState s -> a) -> GenProcess s a
+ Control.Distributed.Process.ManagedProcess.Internal.GenProcess: gets :: (ProcessState s -> a) -> GenProcess s a
- Control.Distributed.Process.ManagedProcess.Internal.GenProcess: push :: forall s. Message -> GenProcess s ()
+ Control.Distributed.Process.ManagedProcess.Internal.GenProcess: push :: Message -> GenProcess s ()
- Control.Distributed.Process.ManagedProcess.Internal.Types: DispatchSTM :: STM a -> (s -> a -> Process (ProcessAction s)) -> Match Message -> (forall m. (Message -> m) -> Match m) -> ExternDispatcher s
+ Control.Distributed.Process.ManagedProcess.Internal.Types: DispatchSTM :: STM a -> (s -> a -> Process (ProcessAction s)) -> Match Message -> (forall m. () => (Message -> m) -> Match m) -> ExternDispatcher s
- Control.Distributed.Process.ManagedProcess.Internal.Types: [matchAnyStm] :: ExternDispatcher s -> forall m. (Message -> m) -> Match m
+ Control.Distributed.Process.ManagedProcess.Internal.Types: [matchAnyStm] :: ExternDispatcher s -> forall m. () => (Message -> m) -> Match m
- Control.Distributed.Process.ManagedProcess.Internal.Types: caller :: forall a b. Message a b -> Maybe Recipient
+ Control.Distributed.Process.ManagedProcess.Internal.Types: caller :: Message a b -> Maybe Recipient
- Control.Distributed.Process.ManagedProcess.Internal.Types: class ExternMatcher d
+ Control.Distributed.Process.ManagedProcess.Internal.Types: class ExternMatcher (d :: Type -> Type)
- Control.Distributed.Process.ManagedProcess.Internal.Types: class MessageMatcher d
+ Control.Distributed.Process.ManagedProcess.Internal.Types: class MessageMatcher (d :: Type -> Type)
- Control.Distributed.Process.ManagedProcess.Internal.Types: initCall :: forall s a b. (Addressable s, Serializable a, Serializable b) => s -> a -> Process (CallRef b)
+ Control.Distributed.Process.ManagedProcess.Internal.Types: initCall :: (Addressable s, Serializable a, Serializable b) => s -> a -> Process (CallRef b)
- Control.Distributed.Process.ManagedProcess.Internal.Types: rejectToCaller :: forall a b. Message a b -> String -> Process ()
+ Control.Distributed.Process.ManagedProcess.Internal.Types: rejectToCaller :: Message a b -> String -> Process ()
- Control.Distributed.Process.ManagedProcess.Internal.Types: type Action s = Process (ProcessAction s)
+ Control.Distributed.Process.ManagedProcess.Internal.Types: type Action s = Process ProcessAction s
- Control.Distributed.Process.ManagedProcess.Internal.Types: type InitHandler a s = a -> Process (InitResult s)
+ Control.Distributed.Process.ManagedProcess.Internal.Types: type InitHandler a s = a -> Process InitResult s
- Control.Distributed.Process.ManagedProcess.Internal.Types: type Reply b s = Process (ProcessReply b s)
+ Control.Distributed.Process.ManagedProcess.Internal.Types: type Reply b s = Process ProcessReply b s
- Control.Distributed.Process.ManagedProcess.Internal.Types: type State s = IORef (ProcessState s)
+ Control.Distributed.Process.ManagedProcess.Internal.Types: type State s = IORef ProcessState s
- Control.Distributed.Process.ManagedProcess.Internal.Types: type StatelessHandler s a = a -> (s -> Action s)
+ Control.Distributed.Process.ManagedProcess.Internal.Types: type StatelessHandler s a = a -> s -> Action s
- Control.Distributed.Process.ManagedProcess.Internal.Types: unsafeInitCall :: forall s a b. (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> Process (CallRef b)
+ Control.Distributed.Process.ManagedProcess.Internal.Types: unsafeInitCall :: (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> Process (CallRef b)
- Control.Distributed.Process.ManagedProcess.Internal.Types: waitResponse :: forall b. Serializable b => Maybe TimeInterval -> CallRef b -> Process (Maybe (Either ExitReason b))
+ Control.Distributed.Process.ManagedProcess.Internal.Types: waitResponse :: Serializable b => Maybe TimeInterval -> CallRef b -> Process (Maybe (Either ExitReason b))
- Control.Distributed.Process.ManagedProcess.Server: become :: forall s. ProcessDefinition s -> s -> Action s
+ Control.Distributed.Process.ManagedProcess.Server: become :: ProcessDefinition s -> s -> Action s
- Control.Distributed.Process.ManagedProcess.Server: condition :: forall a b. (Serializable a, Serializable b) => (a -> b -> Bool) -> Condition a b
+ Control.Distributed.Process.ManagedProcess.Server: condition :: (Serializable a, Serializable b) => (a -> b -> Bool) -> Condition a b
- Control.Distributed.Process.ManagedProcess.Server: handleRaw :: forall s. ActionHandler s Message -> DeferredDispatcher s
+ Control.Distributed.Process.ManagedProcess.Server: handleRaw :: ActionHandler s Message -> DeferredDispatcher s
- Control.Distributed.Process.ManagedProcess.Server.Gen: act :: forall s. GenProcess s () -> Action s
+ Control.Distributed.Process.ManagedProcess.Server.Gen: act :: GenProcess s () -> Action s
- Control.Distributed.Process.ManagedProcess.Server.Gen: become :: forall s. ProcessDefinition s -> GenProcess s (ProcessAction s)
+ Control.Distributed.Process.ManagedProcess.Server.Gen: become :: ProcessDefinition s -> GenProcess s (ProcessAction s)
- Control.Distributed.Process.ManagedProcess.Server.Gen: enqueue :: forall s. Message -> GenProcess s ()
+ Control.Distributed.Process.ManagedProcess.Server.Gen: enqueue :: Message -> GenProcess s ()
- Control.Distributed.Process.ManagedProcess.Server.Gen: eval :: forall s. GenProcess s (ProcessAction s) -> Action s
+ Control.Distributed.Process.ManagedProcess.Server.Gen: eval :: GenProcess s (ProcessAction s) -> Action s
- Control.Distributed.Process.ManagedProcess.Server.Gen: gets :: forall s a. (ProcessState s -> a) -> GenProcess s a
+ Control.Distributed.Process.ManagedProcess.Server.Gen: gets :: (ProcessState s -> a) -> GenProcess s a
- Control.Distributed.Process.ManagedProcess.Server.Gen: push :: forall s. Message -> GenProcess s ()
+ Control.Distributed.Process.ManagedProcess.Server.Gen: push :: Message -> GenProcess s ()
- Control.Distributed.Process.ManagedProcess.Server.Gen: reply :: forall r s. Serializable r => r -> GenProcess s (ProcessReply r s)
+ Control.Distributed.Process.ManagedProcess.Server.Gen: reply :: Serializable r => r -> GenProcess s (ProcessReply r s)
- Control.Distributed.Process.ManagedProcess.Server.Gen: replyWith :: forall r s. Serializable r => r -> ProcessAction s -> GenProcess s (ProcessReply r s)
+ Control.Distributed.Process.ManagedProcess.Server.Gen: replyWith :: Serializable r => r -> ProcessAction s -> GenProcess s (ProcessReply r s)
- Control.Distributed.Process.ManagedProcess.Server.Priority: act :: forall s. GenProcess s () -> Action s
+ Control.Distributed.Process.ManagedProcess.Server.Priority: act :: GenProcess s () -> Action s
- Control.Distributed.Process.ManagedProcess.Server.Priority: api_ :: forall m b s. (Serializable m, Serializable b) => (m -> Process Bool) -> (s -> Message m b -> Process (Filter s)) -> FilterHandler s
+ Control.Distributed.Process.ManagedProcess.Server.Priority: api_ :: (Serializable m, Serializable b) => (m -> Process Bool) -> (s -> Message m b -> Process (Filter s)) -> FilterHandler s
- Control.Distributed.Process.ManagedProcess.Server.Priority: check :: forall s. FilterHandler s -> DispatchFilter s
+ Control.Distributed.Process.ManagedProcess.Server.Priority: check :: FilterHandler s -> DispatchFilter s
- Control.Distributed.Process.ManagedProcess.Server.Priority: crash :: forall s. s -> ExitReason -> Process (Filter s)
+ Control.Distributed.Process.ManagedProcess.Server.Priority: crash :: s -> ExitReason -> Process (Filter s)
- Control.Distributed.Process.ManagedProcess.Server.Priority: ensure :: forall s. (s -> Bool) -> DispatchFilter s
+ Control.Distributed.Process.ManagedProcess.Server.Priority: ensure :: (s -> Bool) -> DispatchFilter s
- Control.Distributed.Process.ManagedProcess.Server.Priority: push :: forall s. Message -> GenProcess s ()
+ Control.Distributed.Process.ManagedProcess.Server.Priority: push :: Message -> GenProcess s ()
- Control.Distributed.Process.ManagedProcess.Server.Priority: raw :: forall s. (s -> Message -> Process Bool) -> (s -> Message -> Process (Maybe (Filter s))) -> FilterHandler s
+ Control.Distributed.Process.ManagedProcess.Server.Priority: raw :: (s -> Message -> Process Bool) -> (s -> Message -> Process (Maybe (Filter s))) -> FilterHandler s
- Control.Distributed.Process.ManagedProcess.Server.Priority: raw_ :: forall s. (Message -> Process Bool) -> (s -> Message -> Process (Maybe (Filter s))) -> FilterHandler s
+ Control.Distributed.Process.ManagedProcess.Server.Priority: raw_ :: (Message -> Process Bool) -> (s -> Message -> Process (Maybe (Filter s))) -> FilterHandler s
- Control.Distributed.Process.ManagedProcess.Server.Priority: safely :: forall s. (s -> Message -> Bool) -> DispatchFilter s
+ Control.Distributed.Process.ManagedProcess.Server.Priority: safely :: (s -> Message -> Bool) -> DispatchFilter s
- Control.Distributed.Process.ManagedProcess.Server.Restricted: continue :: forall s. RestrictedProcess s RestrictedAction
+ Control.Distributed.Process.ManagedProcess.Server.Restricted: continue :: RestrictedProcess s RestrictedAction
- Control.Distributed.Process.ManagedProcess.Server.Restricted: handleTimeout :: forall s. (Delay -> RestrictedProcess s RestrictedAction) -> TimeoutHandler s
+ Control.Distributed.Process.ManagedProcess.Server.Restricted: handleTimeout :: (Delay -> RestrictedProcess s RestrictedAction) -> TimeoutHandler s
- Control.Distributed.Process.ManagedProcess.Server.Restricted: hibernate :: forall s. TimeInterval -> RestrictedProcess s RestrictedAction
+ Control.Distributed.Process.ManagedProcess.Server.Restricted: hibernate :: TimeInterval -> RestrictedProcess s RestrictedAction
- Control.Distributed.Process.ManagedProcess.Server.Restricted: stop :: forall s. ExitReason -> RestrictedProcess s RestrictedAction
+ Control.Distributed.Process.ManagedProcess.Server.Restricted: stop :: ExitReason -> RestrictedProcess s RestrictedAction
- Control.Distributed.Process.ManagedProcess.Server.Restricted: timeoutAfter :: forall s. Delay -> RestrictedProcess s RestrictedAction
+ Control.Distributed.Process.ManagedProcess.Server.Restricted: timeoutAfter :: Delay -> RestrictedProcess s RestrictedAction
- Control.Distributed.Process.ManagedProcess.UnsafeClient: call :: forall s a b. (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> Process b
+ Control.Distributed.Process.ManagedProcess.UnsafeClient: call :: (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> Process b
- Control.Distributed.Process.ManagedProcess.UnsafeClient: callAsync :: forall s a b. (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> Process (Async b)
+ Control.Distributed.Process.ManagedProcess.UnsafeClient: callAsync :: (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> Process (Async b)
- Control.Distributed.Process.ManagedProcess.UnsafeClient: callChan :: forall s a b. (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> Process (ReceivePort b)
+ Control.Distributed.Process.ManagedProcess.UnsafeClient: callChan :: (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> Process (ReceivePort b)
- Control.Distributed.Process.ManagedProcess.UnsafeClient: callTimeout :: forall s a b. (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> TimeInterval -> Process (Maybe b)
+ Control.Distributed.Process.ManagedProcess.UnsafeClient: callTimeout :: (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> TimeInterval -> Process (Maybe b)
- Control.Distributed.Process.ManagedProcess.UnsafeClient: cast :: forall a m. (Addressable a, NFSerializable m) => a -> m -> Process ()
+ Control.Distributed.Process.ManagedProcess.UnsafeClient: cast :: (Addressable a, NFSerializable m) => a -> m -> Process ()
- Control.Distributed.Process.ManagedProcess.UnsafeClient: flushPendingCalls :: forall b. NFSerializable b => TimeInterval -> (b -> Process b) -> Process (Maybe b)
+ Control.Distributed.Process.ManagedProcess.UnsafeClient: flushPendingCalls :: NFSerializable b => TimeInterval -> (b -> Process b) -> Process (Maybe b)
- Control.Distributed.Process.ManagedProcess.UnsafeClient: safeCall :: forall s a b. (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> Process (Either ExitReason b)
+ Control.Distributed.Process.ManagedProcess.UnsafeClient: safeCall :: (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> Process (Either ExitReason b)
- Control.Distributed.Process.ManagedProcess.UnsafeClient: syncCallChan :: forall s a b. (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> Process b
+ Control.Distributed.Process.ManagedProcess.UnsafeClient: syncCallChan :: (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> Process b
- Control.Distributed.Process.ManagedProcess.UnsafeClient: syncSafeCallChan :: forall s a b. (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> Process (Either ExitReason b)
+ Control.Distributed.Process.ManagedProcess.UnsafeClient: syncSafeCallChan :: (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> Process (Either ExitReason b)
- Control.Distributed.Process.ManagedProcess.UnsafeClient: tryCall :: forall s a b. (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> Process (Maybe b)
+ Control.Distributed.Process.ManagedProcess.UnsafeClient: tryCall :: (Addressable s, NFSerializable a, NFSerializable b) => s -> a -> Process (Maybe b)
Files
CHANGELOG.md view
@@ -1,5 +1,9 @@ # Change Log +2024-10-30 David Simmons-Duffin <dsd@caltech.edu> 0.2.7.1++* Bump dependency bound for ansi-terminal+ 2024-10-30 Laurent P. René de Cotret <laurent.decotret@outlook.com> 0.2.7.0 * Removed dependency on `rematch` (#459)
distributed-process-client-server.cabal view
@@ -1,6 +1,6 @@ cabal-version: 3.0 name: distributed-process-client-server-version: 0.2.7.0+version: 0.2.7.1 build-type: Simple license: BSD-3-Clause license-file: LICENCE@@ -73,7 +73,7 @@ x-uses-tf: true build-depends: base >= 4.14 && < 5,- ansi-terminal >= 0.5 && < 0.9,+ ansi-terminal >= 0.5 && < 1.2, containers, distributed-process, distributed-process-extras,