Reflex.Requester.Base.Internal

This module provides RequesterT, the standard implementation of Requester.

Documentation

newtype TagMap (f :: Type -> Type)

Constructors

TagMap (IntMap (Any :: Type))

newtype RequesterData (f :: Type -> Type)

Constructors

RequesterData (TagMap (Entry f))

emptyRequesterData :: forall (f :: Type -> Type). RequesterData f

data RequesterDataKey a where

Constructors

RequesterDataKey_Single :: forall a. !(MyTag (Single a)) -> RequesterDataKey a

RequesterDataKey_Multi :: forall a. !(MyTag Multi) -> !Int -> !(RequesterDataKey a) -> RequesterDataKey a

RequesterDataKey_Multi2 :: forall (k :: Type -> Type) a. GCompare k => !(MyTag (Multi2 k)) -> !(Some k) -> !Int -> !(RequesterDataKey a) -> RequesterDataKey a

RequesterDataKey_Multi3 :: forall a. !(MyTag Multi3) -> !Int -> !Int -> !(RequesterDataKey a) -> RequesterDataKey a

singletonRequesterData :: RequesterDataKey a -> f a -> RequesterData f

mergeRequesterData :: forall (f :: Type -> Type). RequesterData f -> RequesterData f -> RequesterData f

mergeTagMap :: forall (f :: Type -> Type). TagMap (Entry f) -> TagMap (Entry f) -> TagMap (Entry f)

requesterDataToList :: forall (f :: Type -> Type). RequesterData f -> [DSum RequesterDataKey f]

singletonTagMap :: forall f a. MyTag a -> f a -> TagMap f

tagMapToList :: forall (f :: Type -> Type). TagMap f -> [DSum MyTag f]

traverseTagMapWithKey :: Applicative t => (forall a. MyTag a -> f a -> t (g a)) -> TagMap f -> t (TagMap g)

traverseRequesterData :: Applicative m => (forall a. request a -> m (response a)) -> RequesterData request -> m (RequesterData response)

Runs in reverse to accommodate for the fact that we accumulate it in reverse

forRequesterData :: forall request response m. Applicative m => RequesterData request -> (forall a. request a -> m (response a)) -> m (RequesterData response)

traverseRequesterData with its arguments flipped

data MyTagType a where

Constructors

MyTagType_Single :: forall a1. MyTagType (Single a1)

MyTagType_Multi :: MyTagType Multi

MyTagType_Multi2 :: forall (k :: Type -> Type). MyTagType (Multi2 k)

MyTagType_Multi3 :: MyTagType Multi3

myKeyType :: MyTag x -> MyTagType x

data Single a

Instances

MyTagTypeOffset (Single a)

Defined in Reflex.Requester.Base.Internal

Methods

myTagTypeOffset :: proxy (Single a) -> Int

data Multi

Instances

MyTagTypeOffset Multi

Defined in Reflex.Requester.Base.Internal

Methods

myTagTypeOffset :: proxy Multi -> Int

data Multi2 (k :: Type -> Type)

Instances

MyTagTypeOffset (Multi2 k)

Defined in Reflex.Requester.Base.Internal

Methods

myTagTypeOffset :: proxy (Multi2 k) -> Int

data Multi3

Instances

MyTagTypeOffset Multi3

Defined in Reflex.Requester.Base.Internal

Methods

myTagTypeOffset :: proxy Multi3 -> Int

class MyTagTypeOffset x where

Methods

myTagTypeOffset :: proxy x -> Int

Instances

MyTagTypeOffset Multi

Defined in Reflex.Requester.Base.Internal

Methods

myTagTypeOffset :: proxy Multi -> Int

MyTagTypeOffset Multi3

Defined in Reflex.Requester.Base.Internal

Methods

myTagTypeOffset :: proxy Multi3 -> Int

MyTagTypeOffset (Multi2 k)

Defined in Reflex.Requester.Base.Internal

Methods

myTagTypeOffset :: proxy (Multi2 k) -> Int

MyTagTypeOffset (Single a)

Defined in Reflex.Requester.Base.Internal

Methods

myTagTypeOffset :: proxy (Single a) -> Int

type family EntryContents (request :: Type -> Type) a where ...

Equations

EntryContents request (Single a) = request a

EntryContents request Multi = IntMap (RequesterData request)

EntryContents request (Multi2 k) = Multi2Contents k request

EntryContents request Multi3 = IntMap (IntMap (RequesterData request))

data Multi2Contents (k :: Type -> Type) (request :: Type -> Type)

Constructors

Multi2Contents

Fields

• _multi2Contents_dict :: !(Dict (GCompare k))
• _multi2Contents_values :: !(Map (Some k) (IntMap (RequesterData request)))

newtype Entry (request :: Type -> Type) x

Constructors

Entry

Fields

• unEntry :: EntryContents request x

singleEntry :: f a -> Entry f (Single a)

multiEntry :: forall (f :: Type -> Type). IntMap (RequesterData f) -> Entry f Multi

unMultiEntry :: forall (f :: Type -> Type). Entry f Multi -> IntMap (RequesterData f)

newtype MyTag x

We use a hack here to pretend we have x ~ request a; we don't want to use a GADT, because GADTs (even with zero-size existential contexts) can't be newtypes WARNING: This type should never be exposed. In particular, this is extremely unsound if a MyTag from one run of runRequesterT is ever compared against a MyTag from another

Constructors

MyTag Int

Instances

GCompare MyTag

Defined in Reflex.Requester.Base.Internal

Methods

gcompare :: MyTag a -> MyTag b -> GOrdering a b

GEq MyTag

Defined in Reflex.Requester.Base.Internal

Methods

geq :: MyTag a -> MyTag b -> Maybe (a :~: b)

Enum (MyTag x)

Defined in Reflex.Requester.Base.Internal

Methods

succ :: MyTag x -> MyTag x

pred :: MyTag x -> MyTag x

toEnum :: Int -> MyTag x

fromEnum :: MyTag x -> Int

enumFrom :: MyTag x -> [MyTag x]

enumFromThen :: MyTag x -> MyTag x -> [MyTag x]

enumFromTo :: MyTag x -> MyTag x -> [MyTag x]

enumFromThenTo :: MyTag x -> MyTag x -> MyTag x -> [MyTag x]

Show (MyTag x)

Defined in Reflex.Requester.Base.Internal

Methods

showsPrec :: Int -> MyTag x -> ShowS

show :: MyTag x -> String

showList :: [MyTag x] -> ShowS

Eq (MyTag x)

Defined in Reflex.Requester.Base.Internal

Methods

(==) :: MyTag x -> MyTag x -> Bool

(/=) :: MyTag x -> MyTag x -> Bool

Ord (MyTag x)

Defined in Reflex.Requester.Base.Internal

Methods

compare :: MyTag x -> MyTag x -> Ordering

(<) :: MyTag x -> MyTag x -> Bool

(<=) :: MyTag x -> MyTag x -> Bool

(>) :: MyTag x -> MyTag x -> Bool

(>=) :: MyTag x -> MyTag x -> Bool

max :: MyTag x -> MyTag x -> MyTag x

min :: MyTag x -> MyTag x -> MyTag x

newtype MyTagWrap (f :: Type -> Type) x

Constructors

MyTagWrap Int

Instances

GCompare (MyTagWrap f :: Type -> Type)

Defined in Reflex.Requester.Base.Internal

Methods

gcompare :: MyTagWrap f a -> MyTagWrap f b -> GOrdering a b

GEq (MyTagWrap f :: Type -> Type)

Defined in Reflex.Requester.Base.Internal

Methods

geq :: MyTagWrap f a -> MyTagWrap f b -> Maybe (a :~: b)

Enum (MyTagWrap f x)

Defined in Reflex.Requester.Base.Internal

Methods

succ :: MyTagWrap f x -> MyTagWrap f x

pred :: MyTagWrap f x -> MyTagWrap f x

toEnum :: Int -> MyTagWrap f x

fromEnum :: MyTagWrap f x -> Int

enumFrom :: MyTagWrap f x -> [MyTagWrap f x]

enumFromThen :: MyTagWrap f x -> MyTagWrap f x -> [MyTagWrap f x]

enumFromTo :: MyTagWrap f x -> MyTagWrap f x -> [MyTagWrap f x]

enumFromThenTo :: MyTagWrap f x -> MyTagWrap f x -> MyTagWrap f x -> [MyTagWrap f x]

Show (MyTagWrap f x)

Defined in Reflex.Requester.Base.Internal

Methods

showsPrec :: Int -> MyTagWrap f x -> ShowS

show :: MyTagWrap f x -> String

showList :: [MyTagWrap f x] -> ShowS

Eq (MyTagWrap f x)

Defined in Reflex.Requester.Base.Internal

Methods

(==) :: MyTagWrap f x -> MyTagWrap f x -> Bool

(/=) :: MyTagWrap f x -> MyTagWrap f x -> Bool

Ord (MyTagWrap f x)

Defined in Reflex.Requester.Base.Internal

Methods

compare :: MyTagWrap f x -> MyTagWrap f x -> Ordering

(<) :: MyTagWrap f x -> MyTagWrap f x -> Bool

(<=) :: MyTagWrap f x -> MyTagWrap f x -> Bool

(>) :: MyTagWrap f x -> MyTagWrap f x -> Bool

(>=) :: MyTagWrap f x -> MyTagWrap f x -> Bool

max :: MyTagWrap f x -> MyTagWrap f x -> MyTagWrap f x

min :: MyTagWrap f x -> MyTagWrap f x -> MyTagWrap f x

castMyTagWrap :: forall (f :: Type -> Type) x (g :: Type -> Type). MyTagWrap f (Entry f x) -> MyTagWrap g (Entry g x)

data RequesterState t (request :: Type -> Type)

Constructors

RequesterState

Fields

• _requesterState_nextMyTag :: !Int
• _requesterState_requests :: ![(Int, Event t (Any :: Type))]

newtype RequesterT t (request :: Type -> Type) (response :: Type -> Type) (m :: Type -> Type) a

A basic implementation of Requester.

Constructors

RequesterT

Fields

• unRequesterT :: StateT (RequesterState t request) (ReaderT (EventSelectorInt t (Any :: Type)) m) a

Instances

MonadHold t m => MonadHold (t :: Type) (RequesterT t request response m)

Defined in Reflex.Requester.Base.Internal

Methods

hold :: a -> Event t a -> RequesterT t request response m (Behavior t a)

holdDyn :: a -> Event t a -> RequesterT t request response m (Dynamic t a)

holdIncremental :: Patch p => PatchTarget p -> Event t p -> RequesterT t request response m (Incremental t p)

buildDynamic :: PushM t a -> Event t a -> RequesterT t request response m (Dynamic t a)

headE :: Event t a -> RequesterT t request response m (Event t a)

now :: RequesterT t request response m (Event t ())

MonadSample t m => MonadSample (t :: Type) (RequesterT t request response m)

Defined in Reflex.Requester.Base.Internal

Methods

sample :: Behavior t a -> RequesterT t request response m a

EventWriter t w m => EventWriter t w (RequesterT t request response m)

Defined in Reflex.Requester.Base.Internal

Methods

tellEvent :: Event t w -> RequesterT t request response m ()

MFunctor (RequesterT t request response :: (Type -> Type) -> Type -> Type)

Defined in Reflex.Requester.Base.Internal

Methods

hoist :: Monad m => (forall a. m a -> n a) -> RequesterT t request response m b -> RequesterT t request response n b

MonadReader r m => MonadReader r (RequesterT t request response m)

Defined in Reflex.Requester.Base.Internal

Methods

ask :: RequesterT t request response m r

local :: (r -> r) -> RequesterT t request response m a -> RequesterT t request response m a

reader :: (r -> a) -> RequesterT t request response m a

(Reflex t, Adjustable t m, MonadHold t m, MonadFix m) => Adjustable t (RequesterT t request response m)

Defined in Reflex.Requester.Base.Internal

Methods

runWithReplace :: RequesterT t request response m a -> Event t (RequesterT t request response m b) -> RequesterT t request response m (a, Event t b)

traverseIntMapWithKeyWithAdjust :: (Key -> v -> RequesterT t request response m v') -> IntMap v -> Event t (PatchIntMap v) -> RequesterT t request response m (IntMap v', Event t (PatchIntMap v'))

traverseDMapWithKeyWithAdjust :: GCompare k => (forall a. k a -> v a -> RequesterT t request response m (v' a)) -> DMap k v -> Event t (PatchDMap k v) -> RequesterT t request response m (DMap k v', Event t (PatchDMap k v'))

traverseDMapWithKeyWithAdjustWithMove :: GCompare k => (forall a. k a -> v a -> RequesterT t request response m (v' a)) -> DMap k v -> Event t (PatchDMapWithMove k v) -> RequesterT t request response m (DMap k v', Event t (PatchDMapWithMove k v'))

MonadReflexCreateTrigger t m => MonadReflexCreateTrigger t (RequesterT t request response m)

Defined in Reflex.Requester.Base.Internal

Methods

newEventWithTrigger :: (EventTrigger t a -> IO (IO ())) -> RequesterT t request response m (Event t a)

newFanEventWithTrigger :: GCompare k => (forall a. k a -> EventTrigger t a -> IO (IO ())) -> RequesterT t request response m (EventSelector t k)

NotReady t m => NotReady t (RequesterT t request response m)

Defined in Reflex.NotReady.Class

Methods

notReadyUntil :: Event t a -> RequesterT t request response m ()

notReady :: RequesterT t request response m ()

PerformEvent t m => PerformEvent t (RequesterT t request response m)

Defined in Reflex.Requester.Base.Internal

Associated Types

type Performable (RequesterT t request response m)

Defined in Reflex.Requester.Base.Internal

type Performable (RequesterT t request response m) = Performable m

Methods

performEvent :: Event t (Performable (RequesterT t request response m) a) -> RequesterT t request response m (Event t a)

performEvent_ :: Event t (Performable (RequesterT t request response m) ()) -> RequesterT t request response m ()

PostBuild t m => PostBuild t (RequesterT t request response m)

Defined in Reflex.Requester.Base.Internal

Methods

getPostBuild :: RequesterT t request response m (Event t ())

(Reflex t, Monad m) => Requester t (RequesterT t request response m)

Defined in Reflex.Requester.Base.Internal

Associated Types

type Request (RequesterT t request response m)

Defined in Reflex.Requester.Base.Internal

type Request (RequesterT t request response m) = request

type Response (RequesterT t request response m)

Defined in Reflex.Requester.Base.Internal

type Response (RequesterT t request response m) = response

Methods

requesting :: Event t (Request (RequesterT t request response m) a) -> RequesterT t request response m (Event t (Response (RequesterT t request response m) a))

requesting_ :: Event t (Request (RequesterT t request response m) a) -> RequesterT t request response m ()

TriggerEvent t m => TriggerEvent t (RequesterT t request response m)

Defined in Reflex.Requester.Base.Internal

Methods

newTriggerEvent :: RequesterT t request response m (Event t a, a -> IO ())

newTriggerEventWithOnComplete :: RequesterT t request response m (Event t a, a -> IO () -> IO ())

newEventWithLazyTriggerWithOnComplete :: ((a -> IO () -> IO ()) -> IO (IO ())) -> RequesterT t request response m (Event t a)

MonadTrans (RequesterT t request response)

Defined in Reflex.Requester.Base.Internal

Methods

lift :: Monad m => m a -> RequesterT t request response m a

MonadAsyncException m => MonadAsyncException (RequesterT t request response m)

Defined in Reflex.Requester.Base.Internal

Methods

mask :: ((forall a. RequesterT t request response m a -> RequesterT t request response m a) -> RequesterT t request response m b) -> RequesterT t request response m b

MonadException m => MonadException (RequesterT t request response m)

Defined in Reflex.Requester.Base.Internal

Methods

throw :: Exception e => e -> RequesterT t request response m a

catch :: Exception e => RequesterT t request response m a -> (e -> RequesterT t request response m a) -> RequesterT t request response m a

finally :: RequesterT t request response m a -> RequesterT t request response m b -> RequesterT t request response m a

MonadCatch m => MonadCatch (RequesterT t request response m)

Defined in Reflex.Requester.Base.Internal

Methods

catch :: (HasCallStack, Exception e) => RequesterT t request response m a -> (e -> RequesterT t request response m a) -> RequesterT t request response m a

MonadMask m => MonadMask (RequesterT t request response m)

Defined in Reflex.Requester.Base.Internal

Methods

mask :: HasCallStack => ((forall a. RequesterT t request response m a -> RequesterT t request response m a) -> RequesterT t request response m b) -> RequesterT t request response m b

uninterruptibleMask :: HasCallStack => ((forall a. RequesterT t request response m a -> RequesterT t request response m a) -> RequesterT t request response m b) -> RequesterT t request response m b

generalBracket :: HasCallStack => RequesterT t request response m a -> (a -> ExitCase b -> RequesterT t request response m c) -> (a -> RequesterT t request response m b) -> RequesterT t request response m (b, c)

MonadThrow m => MonadThrow (RequesterT t request response m)

Defined in Reflex.Requester.Base.Internal

Methods

throwM :: (HasCallStack, Exception e) => e -> RequesterT t request response m a

Monad m => Applicative (RequesterT t request response m)

Defined in Reflex.Requester.Base.Internal

Methods

pure :: a -> RequesterT t request response m a

(<*>) :: RequesterT t request response m (a -> b) -> RequesterT t request response m a -> RequesterT t request response m b

liftA2 :: (a -> b -> c) -> RequesterT t request response m a -> RequesterT t request response m b -> RequesterT t request response m c

(*>) :: RequesterT t request response m a -> RequesterT t request response m b -> RequesterT t request response m b

(<*) :: RequesterT t request response m a -> RequesterT t request response m b -> RequesterT t request response m a

Functor m => Functor (RequesterT t request response m)

Defined in Reflex.Requester.Base.Internal

Methods

fmap :: (a -> b) -> RequesterT t request response m a -> RequesterT t request response m b

(<$) :: a -> RequesterT t request response m b -> RequesterT t request response m a

Monad m => Monad (RequesterT t request response m)

Defined in Reflex.Requester.Base.Internal

Methods

(>>=) :: RequesterT t request response m a -> (a -> RequesterT t request response m b) -> RequesterT t request response m b

(>>) :: RequesterT t request response m a -> RequesterT t request response m b -> RequesterT t request response m b

return :: a -> RequesterT t request response m a

MonadFix m => MonadFix (RequesterT t request response m)

Defined in Reflex.Requester.Base.Internal

Methods

mfix :: (a -> RequesterT t request response m a) -> RequesterT t request response m a

MonadIO m => MonadIO (RequesterT t request response m)

Defined in Reflex.Requester.Base.Internal

Methods

liftIO :: IO a -> RequesterT t request response m a

PrimMonad m => PrimMonad (RequesterT t request response m)

Defined in Reflex.Requester.Base.Internal

Associated Types

type PrimState (RequesterT t request response m)

Defined in Reflex.Requester.Base.Internal

type PrimState (RequesterT t request response m) = PrimState m

Methods

primitive :: (State# (PrimState (RequesterT t request response m)) -> (# State# (PrimState (RequesterT t request response m)), a #)) -> RequesterT t request response m a

MonadRef m => MonadRef (RequesterT t request response m)

Defined in Reflex.Requester.Base.Internal

Associated Types

type Ref (RequesterT t request response m)

Defined in Reflex.Requester.Base.Internal

type Ref (RequesterT t request response m) = Ref m

Methods

newRef :: a -> RequesterT t request response m (Ref (RequesterT t request response m) a)

readRef :: Ref (RequesterT t request response m) a -> RequesterT t request response m a

writeRef :: Ref (RequesterT t request response m) a -> a -> RequesterT t request response m ()

modifyRef :: Ref (RequesterT t request response m) a -> (a -> a) -> RequesterT t request response m ()

modifyRef' :: Ref (RequesterT t request response m) a -> (a -> a) -> RequesterT t request response m ()

(Monoid a, Monad m) => Monoid (RequesterT t request response m a)

Defined in Reflex.Requester.Base.Internal

Methods

mempty :: RequesterT t request response m a

mappend :: RequesterT t request response m a -> RequesterT t request response m a -> RequesterT t request response m a

mconcat :: [RequesterT t request response m a] -> RequesterT t request response m a

(Semigroup a, Monad m) => Semigroup (RequesterT t request response m a)

Defined in Reflex.Requester.Base.Internal

Methods

(<>) :: RequesterT t request response m a -> RequesterT t request response m a -> RequesterT t request response m a

sconcat :: NonEmpty (RequesterT t request response m a) -> RequesterT t request response m a

stimes :: Integral b => b -> RequesterT t request response m a -> RequesterT t request response m a

type PrimState (RequesterT t request response m)

Defined in Reflex.Requester.Base.Internal

type PrimState (RequesterT t request response m) = PrimState m

type Ref (RequesterT t request response m)

Defined in Reflex.Requester.Base.Internal

type Ref (RequesterT t request response m) = Ref m

type Performable (RequesterT t request response m)

Defined in Reflex.Requester.Base.Internal

type Performable (RequesterT t request response m) = Performable m

type Request (RequesterT t request response m)

Defined in Reflex.Requester.Base.Internal

type Request (RequesterT t request response m) = request

type Response (RequesterT t request response m)

Defined in Reflex.Requester.Base.Internal

type Response (RequesterT t request response m) = response

runRequesterT :: forall t m (request :: Type -> Type) (response :: Type -> Type) a. (Reflex t, Monad m) => RequesterT t request response m a -> Event t (RequesterData response) -> m (a, Event t (RequesterData request))

Run a RequesterT action. The resulting Event will fire whenever requests are made, and responses should be provided in the input Event. The Tag keys will be used to return the responses to the same place the requests were issued.

withRequesterT

Arguments

:: forall t (m :: Type -> Type) req req' rsp' rsp a. (Reflex t, MonadFix m)

=> (forall x. req x -> req' x)

The function to map over the request

-> (forall x. rsp' x -> rsp x)

The function to map over the response

-> RequesterT t req rsp m a

The internal RequesterT whose input and output will be transformed

-> RequesterT t req' rsp' m a

The resulting RequesterT

Map a function over the request and response of a RequesterT

tagRequest :: forall (m :: Type -> Type) x t (request :: Type -> Type) (response :: Type -> Type). (Monad m, MyTagTypeOffset x) => Event t (Entry request x) -> RequesterT t request response m (MyTagWrap request (Entry request x))

responseFromTag :: forall (m :: Type -> Type) t (request :: Type -> Type) (response :: Type -> Type) x. Monad m => MyTagWrap response (Entry response x) -> RequesterT t request response m (Event t (Entry response x))

requesting' :: forall x (m :: Type -> Type) t (request :: Type -> Type) (response :: Type -> Type). (MyTagTypeOffset x, Monad m) => Event t (Entry request x) -> RequesterT t request response m (Event t (Entry response x))

runWithReplaceRequesterTWith :: forall m t (request :: Type -> Type) (response :: Type -> Type) a b. (Reflex t, MonadHold t m, MonadFix m) => (forall a' b'. m a' -> Event t (m b') -> RequesterT t request response m (a', Event t b')) -> RequesterT t request response m a -> Event t (RequesterT t request response m b) -> RequesterT t request response m (a, Event t b)

traverseIntMapWithKeyWithAdjustRequesterTWith :: forall t (request :: Type -> Type) (response :: Type -> Type) m v v' p. (Reflex t, MonadHold t m, PatchTarget (p (Event t (IntMap (RequesterData request)))) ~ IntMap (Event t (IntMap (RequesterData request))), Patch (p (Event t (IntMap (RequesterData request)))), Functor p, MonadFix m) => ((Key -> (Key, v) -> m (Event t (IntMap (RequesterData request)), v')) -> IntMap (Key, v) -> Event t (p (Key, v)) -> RequesterT t request response m (IntMap (Event t (IntMap (RequesterData request)), v'), Event t (p (Event t (IntMap (RequesterData request)), v')))) -> (p (Event t (IntMap (RequesterData request))) -> IntMap (Event t (IntMap (RequesterData request)))) -> (Incremental t (p (Event t (IntMap (RequesterData request)))) -> Event t (IntMap (IntMap (RequesterData request)))) -> (Key -> v -> RequesterT t request response m v') -> IntMap v -> Event t (p v) -> RequesterT t request response m (IntMap v', Event t (p v'))

traverseDMapWithKeyWithAdjustRequesterTWith :: forall k t (request :: Type -> Type) (response :: Type -> Type) m v v' p p'. (GCompare k, Reflex t, MonadHold t m, PatchTarget (p' (Some k) (Event t (IntMap (RequesterData request)))) ~ Map (Some k) (Event t (IntMap (RequesterData request))), Patch (p' (Some k) (Event t (IntMap (RequesterData request)))), MonadFix m) => (forall (k' :: Type -> Type) (v1 :: Type -> Type) (v2 :: Type -> Type). GCompare k' => (forall a. k' a -> v1 a -> m (v2 a)) -> DMap k' v1 -> Event t (p k' v1) -> RequesterT t request response m (DMap k' v2, Event t (p k' v2))) -> (forall (v1 :: Type -> Type) (v2 :: Type -> Type). (forall a. v1 a -> v2 a) -> p k v1 -> p k v2) -> (forall (v1 :: Type -> Type) v2. (forall a. v1 a -> v2) -> p k v1 -> p' (Some k) v2) -> (forall v2. p' (Some k) v2 -> Map (Some k) v2) -> (forall a. Incremental t (p' (Some k) (Event t a)) -> Event t (Map (Some k) a)) -> (forall a. k a -> v a -> RequesterT t request response m (v' a)) -> DMap k v -> Event t (p k v) -> RequesterT t request response m (DMap k v', Event t (p k v'))

data Decoder rawResponse (response :: Type -> Type)

Constructors

Decoder (RequesterDataKey a) (rawResponse -> response a)

matchResponsesWithRequests

Arguments

:: forall t rawRequest rawResponse request response m. (MonadFix m, MonadHold t m, Reflex t)

=> (forall a. request a -> (rawRequest, rawResponse -> response a))

Given a request (from Requester), produces the wire format of the request and a function used to process the associated response

-> Event t (RequesterData request)

The outgoing requests

-> Event t (Int, rawResponse)

The incoming responses, tagged by an identifying key

-> m (Event t (Map Int rawRequest), Event t (RequesterData response))

A map of outgoing wire-format requests and an event of responses keyed by the RequesterData key of the associated outgoing request

matchResponseMapWithRequests

Arguments

:: forall t rawRequest rawResponse request response m. (MonadFix m, MonadHold t m, Reflex t)

=> (forall a. request a -> (rawRequest, rawResponse -> response a))

Given a request (from Requester), produces the wire format of the request and a function used to process the associated response

-> Event t (RequesterData request)

The outgoing requests

-> Event t (Map Int rawResponse)

A map of incoming responses, tagged by an identifying key

-> m (Event t (Map Int rawRequest), Event t (RequesterData response))

A map of outgoing wire-format requests and an event of responses keyed by the RequesterData key of the associated outgoing request

Matches incoming responses with previously-sent requests and uses the provided request "decoder" function to process incoming responses.