Safe Haskell	None
Language	Haskell2010

Control.Eff.Concurrent.Protocol.Request

Description

Proxies and containers for casts and calls.

Since: 0.15.0

Synopsis

data Request protocol where
- Call :: forall protocol reply. (Tangible reply, TangiblePdu protocol (Synchronous reply)) => RequestOrigin protocol reply -> Pdu protocol (Synchronous reply) -> Request protocol
- Cast :: forall protocol. (TangiblePdu protocol Asynchronous, NFData (Pdu protocol Asynchronous)) => Pdu protocol Asynchronous -> Request protocol
sendReply :: (SetMember Process (Process q) eff, Member Interrupts eff, Tangible reply, Typeable protocol) => Serializer (Reply protocol reply) -> RequestOrigin protocol reply -> reply -> Eff eff ()
data RequestOrigin (proto :: Type) reply = RequestOrigin {
- _requestOriginPid :: !ProcessId
- _requestOriginCallRef :: !Int
}
embedRequestOrigin :: EmbedProtocol outer inner => RequestOrigin inner reply -> RequestOrigin outer reply
data Reply protocol reply where
- Reply :: Tangible reply => {..} -> Reply protocol reply
embedReplySerializer :: EmbedProtocol outer inner => Serializer (Reply outer reply) -> Serializer (Reply inner reply)
makeRequestOrigin :: (Typeable r, NFData r, SetMember Process (Process q0) e, '[Interrupts] <:: e) => Eff e (RequestOrigin p r)

Documentation

data Request protocol where Source #

A wrapper sum type for calls and casts for the Pdus of a protocol

Since: 0.15.0

Constructors

Call :: forall protocol reply. (Tangible reply, TangiblePdu protocol (Synchronous reply)) => RequestOrigin protocol reply -> Pdu protocol (Synchronous reply) -> Request protocol
Cast :: forall protocol. (TangiblePdu protocol Asynchronous, NFData (Pdu protocol Asynchronous)) => Pdu protocol Asynchronous -> Request protocol

Instances

Show (Request protocol) Source #
Instance details Defined in Control.Eff.Concurrent.Protocol.Request Methods showsPrec :: Int -> Request protocol -> ShowS # show :: Request protocol -> String # showList :: [Request protocol] -> ShowS #
NFData (Request protocol) Source #
Instance details Defined in Control.Eff.Concurrent.Protocol.Request Methods rnf :: Request protocol -> () #

sendReply :: (SetMember Process (Process q) eff, Member Interrupts eff, Tangible reply, Typeable protocol) => Serializer (Reply protocol reply) -> RequestOrigin protocol reply -> reply -> Eff eff () Source #

Send a Reply to a Call.

The reply will be deeply evaluated to rnf.

To send replies for EmbedProtocol instances use embedReplySerializer.

Since: 0.15.0

data RequestOrigin (proto :: Type) reply Source #

Wraps the source ProcessId and a unique identifier for a Call.

Since: 0.15.0

Constructors

RequestOrigin
Fields _requestOriginPid :: !ProcessId _requestOriginCallRef :: !Int

Instances

Eq (RequestOrigin proto reply) Source #
Instance details Defined in Control.Eff.Concurrent.Protocol.Request Methods (==) :: RequestOrigin proto reply -> RequestOrigin proto reply -> Bool # (/=) :: RequestOrigin proto reply -> RequestOrigin proto reply -> Bool #
Ord (RequestOrigin proto reply) Source #
Instance details Defined in Control.Eff.Concurrent.Protocol.Request Methods compare :: RequestOrigin proto reply -> RequestOrigin proto reply -> Ordering # (<) :: RequestOrigin proto reply -> RequestOrigin proto reply -> Bool # (<=) :: RequestOrigin proto reply -> RequestOrigin proto reply -> Bool # (>) :: RequestOrigin proto reply -> RequestOrigin proto reply -> Bool # (>=) :: RequestOrigin proto reply -> RequestOrigin proto reply -> Bool # max :: RequestOrigin proto reply -> RequestOrigin proto reply -> RequestOrigin proto reply # min :: RequestOrigin proto reply -> RequestOrigin proto reply -> RequestOrigin proto reply #
Show (RequestOrigin p r) Source #
Instance details Defined in Control.Eff.Concurrent.Protocol.Request Methods showsPrec :: Int -> RequestOrigin p r -> ShowS # show :: RequestOrigin p r -> String # showList :: [RequestOrigin p r] -> ShowS #
Generic (RequestOrigin proto reply) Source #
Instance details Defined in Control.Eff.Concurrent.Protocol.Request Associated Types type Rep (RequestOrigin proto reply) :: Type -> Type # Methods from :: RequestOrigin proto reply -> Rep (RequestOrigin proto reply) x # to :: Rep (RequestOrigin proto reply) x -> RequestOrigin proto reply #
NFData (RequestOrigin p r) Source #
Instance details Defined in Control.Eff.Concurrent.Protocol.Request Methods rnf :: RequestOrigin p r -> () #
type Rep (RequestOrigin proto reply) Source #
Instance details Defined in Control.Eff.Concurrent.Protocol.Request type Rep (RequestOrigin proto reply) = D1 (MetaData "RequestOrigin" "Control.Eff.Concurrent.Protocol.Request" "extensible-effects-concurrent-0.24.2-4i89KX4lrqK4F8mqMzm4qM" False) (C1 (MetaCons "RequestOrigin" PrefixI True) (S1 (MetaSel (Just "_requestOriginPid") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 ProcessId) :*: S1 (MetaSel (Just "_requestOriginCallRef") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Int)))

embedRequestOrigin :: EmbedProtocol outer inner => RequestOrigin inner reply -> RequestOrigin outer reply Source #

Turn an embedded RequestOrigin to a RequestOrigin for the bigger request.

This function is strict in all parameters.

This is useful of a server delegates the calls and casts for an embedded protocol to functions, that require the Serializer and RequestOrigin in order to call sendReply.

Show r => Show (Reply p r) Source #
Instance details Defined in Control.Eff.Concurrent.Protocol.Request Methods showsPrec :: Int -> Reply p r -> ShowS # show :: Reply p r -> String # showList :: [Reply p r] -> ShowS #
NFData (Reply p r) Source #
Instance details Defined in Control.Eff.Concurrent.Protocol.Request Methods rnf :: Reply p r -> () #

Reply
Fields :: Tangible reply => { _replyTo :: RequestOrigin protocol reply , _replyValue :: reply } -> Reply protocol reply