Reflex.Spider.Internal

Synopsis

• debugPropagate :: Bool
• debugInvalidateHeight :: Bool
• showNodeId :: a -> String
• data Hold a = Hold {
  • holdValue :: !(IORef a)
  • holdInvalidators :: !(IORef [Weak Invalidator])
  • holdSubscriber :: !(IORef Any)
  • holdParent :: !(IORef Any)
  }
• data EventEnv = EventEnv {
  • eventEnvAssignments :: !(IORef [SomeAssignment])
  • eventEnvHoldInits :: !(IORef [SomeHoldInit])
  • eventEnvClears :: !(IORef [SomeMaybeIORef])
  • eventEnvCurrentHeight :: !(IORef Int)
  • eventEnvCoincidenceInfos :: !(IORef [SomeCoincidenceInfo])
  • eventEnvDelayedMerges :: !(IORef (IntMap [DelayedMerge]))
  }
• runEventM :: EventM a -> EventEnv -> IO a
• askToAssignRef :: EventM (IORef [SomeAssignment])
• askHoldInitRef :: EventM (IORef [SomeHoldInit])
• getCurrentHeight :: EventM Int
• putCurrentHeight :: Int -> EventM ()
• scheduleClear :: IORef (Maybe a) -> EventM ()
• scheduleMerge :: Int -> MergeSubscribed a -> EventM ()
• emitCoincidenceInfo :: SomeCoincidenceInfo -> EventM ()
• hold :: a -> Event a -> EventM (Behavior a)
• subscribeHold :: Event a -> Hold a -> EventM ()
• newtype BehaviorM a = BehaviorM {
  • unBehaviorM :: ReaderT (Maybe (Weak Invalidator, IORef [SomeBehaviorSubscribed])) IO a
  }
• data BehaviorSubscribed a
  • = BehaviorSubscribedHold (Hold a)
  • | BehaviorSubscribedPull (PullSubscribed a)
• data SomeBehaviorSubscribed = forall a . SomeBehaviorSubscribed (BehaviorSubscribed a)
• data PullSubscribed a = PullSubscribed {
  • pullSubscribedValue :: !a
  • pullSubscribedInvalidators :: !(IORef [Weak Invalidator])
  • pullSubscribedOwnInvalidator :: !Invalidator
  • pullSubscribedParents :: ![SomeBehaviorSubscribed]
  }
• data Pull a = Pull {
  • pullValue :: !(IORef (Maybe (PullSubscribed a)))
  • pullCompute :: !(BehaviorM a)
  }
• data Invalidator
  • = forall a . InvalidatorPull (Pull a)
  • | forall a . InvalidatorSwitch (SwitchSubscribed a)
• data RootSubscribed a = RootSubscribed {
  • rootSubscribedSubscribers :: !(IORef [WeakSubscriber a])
  • rootSubscribedOccurrence :: !(IORef (Maybe a))
  }
• data Root a = Root {
  • rootOccurrence :: !(IORef (Maybe a))
  • rootSubscribed :: !(IORef (Maybe (RootSubscribed a)))
  • rootInit :: !(RootTrigger a -> IO (IO ()))
  }
• data SomeHoldInit = forall a . SomeHoldInit (Event a) (Hold a)
• newtype EventM a = EventM {
  • unEventM :: ReaderT EventEnv IO a
  }
• data PushSubscribed a b = PushSubscribed {
  • pushSubscribedOccurrence :: !(IORef (Maybe b))
  • pushSubscribedHeight :: !(IORef Int)
  • pushSubscribedSubscribers :: !(IORef [WeakSubscriber b])
  • pushSubscribedSelf :: !(Subscriber a)
  • pushSubscribedParent :: !(EventSubscribed a)
  }
• data Push a b = Push {
  • pushCompute :: !(a -> EventM (Maybe b))
  • pushParent :: !(Event a)
  • pushSubscribed :: !(IORef (Maybe (PushSubscribed a b)))
  }
• data MergeSubscribed k = MergeSubscribed {
  • mergeSubscribedOccurrence :: !(IORef (Maybe (DMap k)))
  • mergeSubscribedAccum :: !(IORef (DMap k))
  • mergeSubscribedHeight :: !(IORef Int)
  • mergeSubscribedSubscribers :: !(IORef [WeakSubscriber (DMap k)])
  • mergeSubscribedSelf :: !Any
  • mergeSubscribedParents :: !(DMap (WrapArg EventSubscribed k))
  }
• data Merge k = Merge {
  • mergeParents :: !(DMap (WrapArg Event k))
  • mergeSubscribed :: !(IORef (Maybe (MergeSubscribed k)))
  }
• data FanSubscriberKey k a where
  • FanSubscriberKey :: k a -> FanSubscriberKey k [WeakSubscriber a]
• data FanSubscribed k = FanSubscribed {
  • fanSubscribedSubscribers :: !(IORef (DMap (FanSubscriberKey k)))
  • fanSubscribedParent :: !(EventSubscribed (DMap k))
  • fanSubscribedSelf :: !(Subscriber (DMap k))
  }
• data Fan k = Fan {
  • fanParent :: !(Event (DMap k))
  • fanSubscribed :: !(IORef (Maybe (FanSubscribed k)))
  }
• data SwitchSubscribed a = SwitchSubscribed {
  • switchSubscribedOccurrence :: !(IORef (Maybe a))
  • switchSubscribedHeight :: !(IORef Int)
  • switchSubscribedSubscribers :: !(IORef [WeakSubscriber a])
  • switchSubscribedSelf :: !(Subscriber a)
  • switchSubscribedSelfWeak :: !(IORef (Weak (Subscriber a)))
  • switchSubscribedOwnInvalidator :: !Invalidator
  • switchSubscribedOwnWeakInvalidator :: !(IORef (Weak Invalidator))
  • switchSubscribedBehaviorParents :: !(IORef [SomeBehaviorSubscribed])
  • switchSubscribedParent :: !(Behavior (Event a))
  • switchSubscribedCurrentParent :: !(IORef (EventSubscribed a))
  }
• data Switch a = Switch {
  • switchParent :: !(Behavior (Event a))
  • switchSubscribed :: !(IORef (Maybe (SwitchSubscribed a)))
  }
• data CoincidenceSubscribed a = CoincidenceSubscribed {
  • coincidenceSubscribedOccurrence :: !(IORef (Maybe a))
  • coincidenceSubscribedSubscribers :: !(IORef [WeakSubscriber a])
  • coincidenceSubscribedHeight :: !(IORef Int)
  • coincidenceSubscribedOuter :: !(Subscriber (Event a))
  • coincidenceSubscribedOuterParent :: !(EventSubscribed (Event a))
  • coincidenceSubscribedInnerParent :: !(IORef (Maybe (EventSubscribed a)))
  }
• data Coincidence a = Coincidence {
  • coincidenceParent :: !(Event (Event a))
  • coincidenceSubscribed :: !(IORef (Maybe (CoincidenceSubscribed a)))
  }
• data Box a = Box {
  • unBox :: a
  }
• data WeakSubscriber a
  • = forall k . GCompare k => WeakSubscriberMerge !(k a) !(Weak (Box (MergeSubscribed k)))
  • | WeakSubscriberSimple !(Weak (Subscriber a))
• showWeakSubscriberType :: WeakSubscriber a -> String
• deRefWeakSubscriber :: WeakSubscriber a -> IO (Maybe (Subscriber a))
• data Subscriber a
  • = forall b . SubscriberPush !(a -> EventM (Maybe b)) (PushSubscribed a b)
  • | forall k . GCompare k => SubscriberMerge !(k a) (MergeSubscribed k)
  • | forall k . (GCompare k, a ~ DMap k) => SubscriberFan (FanSubscribed k)
  • | SubscriberHold !(Hold a)
  • | SubscriberSwitch (SwitchSubscribed a)
  • | forall b . (a ~ Event b) => SubscriberCoincidenceOuter (CoincidenceSubscribed b)
  • | SubscriberCoincidenceInner (CoincidenceSubscribed a)
• showSubscriberType :: Subscriber a -> String
• data Event a
  • = EventRoot !(Root a)
  • | EventNever
  • | forall b . EventPush !(Push b a)
  • | forall k . (GCompare k, a ~ DMap k) => EventMerge !(Merge k)
  • | forall k . GCompare k => EventFan !(k a) !(Fan k)
  • | EventSwitch !(Switch a)
  • | EventCoincidence !(Coincidence a)
• showEventType :: Event a -> String
• data EventSubscribed a
  • = EventSubscribedRoot !(RootSubscribed a)
  • | EventSubscribedNever
  • | forall b . EventSubscribedPush !(PushSubscribed b a)
  • | forall k . (GCompare k, a ~ DMap k) => EventSubscribedMerge !(MergeSubscribed k)
  • | forall k . GCompare k => EventSubscribedFan !(k a) !(FanSubscribed k)
  • | EventSubscribedSwitch !(SwitchSubscribed a)
  • | EventSubscribedCoincidence !(CoincidenceSubscribed a)
• data Behavior a
  • = BehaviorHold !(Hold a)
  • | BehaviorConst !a
  • | BehaviorPull !(Pull a)
• type ResultM = EventM
• unsafeNewIORef :: a -> b -> IORef b
• push :: (a -> EventM (Maybe b)) -> Event a -> Event b
• pull :: BehaviorM a -> Behavior a
• switch :: Behavior (Event a) -> Event a
• coincidence :: Event (Event a) -> Event a
• newRoot :: IO (Root a)
• propagateAndUpdateSubscribersRef :: IORef [WeakSubscriber a] -> a -> EventM ()
• run :: [DSum RootTrigger] -> ResultM b -> IO b
• data SomeMaybeIORef = forall a . SomeMaybeIORef (IORef (Maybe a))
• data SomeAssignment = forall a . SomeAssignment (Hold a) a
• data DelayedMerge = forall k . DelayedMerge (MergeSubscribed k)
• debugFinalize :: Bool
• mkWeakPtrWithDebug :: a -> String -> IO (Weak a)
• type WeakList a = [Weak a]
• traverseAndCleanWeakList_ :: Monad m => (wa -> m (Maybe a)) -> [wa] -> (a -> m ()) -> m [wa]
• propagate :: a -> [WeakSubscriber a] -> EventM [WeakSubscriber a]
• data SomeCoincidenceInfo = forall a . SomeCoincidenceInfo (Weak (Subscriber a)) (Subscriber a) (Maybe (CoincidenceSubscribed a))
• subscribeCoincidenceInner :: Event a -> Int -> CoincidenceSubscribed a -> EventM (Maybe a, Int, EventSubscribed a)
• readBehavior :: Behavior a -> IO a
• runBehaviorM :: BehaviorM a -> Maybe (Weak Invalidator, IORef [SomeBehaviorSubscribed]) -> IO a
• askInvalidator :: BehaviorM (Maybe (Weak Invalidator))
• askParentsRef :: BehaviorM (Maybe (IORef [SomeBehaviorSubscribed]))
• readBehaviorTracked :: Behavior a -> BehaviorM a
• readEvent :: Event a -> ResultM (Maybe a)
• zeroRef :: IORef Int
• getEventSubscribed :: Event a -> EventM (EventSubscribed a)
• debugSubscribe :: Bool
• subscribeEventSubscribed :: EventSubscribed a -> WeakSubscriber a -> IO ()
• getEventSubscribedOcc :: EventSubscribed a -> IO (Maybe a)
• eventSubscribedHeightRef :: EventSubscribed a -> IORef Int
• subscribe :: Event a -> WeakSubscriber a -> EventM (EventSubscribed a)
• getRootSubscribed :: Root a -> EventM (RootSubscribed a)
• getPushSubscribed :: Push a b -> EventM (PushSubscribed a b)
• getMergeSubscribed :: forall k. GCompare k => Merge k -> EventM (MergeSubscribed k)
• getFanSubscribed :: GCompare k => Fan k -> EventM (FanSubscribed k)
• getSwitchSubscribed :: Switch a -> EventM (SwitchSubscribed a)
• getCoincidenceSubscribed :: forall a. Coincidence a -> EventM (CoincidenceSubscribed a)
• merge :: GCompare k => DMap (WrapArg Event k) -> Event (DMap k)
• newtype EventSelector k = EventSelector {
  • select :: forall a. k a -> Event a
  }
• fan :: GCompare k => Event (DMap k) -> EventSelector k
• runFrame :: EventM a -> IO a
• invalidHeight :: Int
• invalidateSubscriberHeight :: WeakSubscriber a -> IO ()
• invalidateCoincidenceHeight :: CoincidenceSubscribed a -> IO ()
• recalculateSubscriberHeight :: WeakSubscriber a -> IO ()
• recalculateCoincidenceHeight :: CoincidenceSubscribed a -> IO ()
• calculateMergeHeight :: MergeSubscribed k -> IO Int
• calculateSwitchHeight :: SwitchSubscribed a -> IO Int
• calculateCoincidenceHeight :: CoincidenceSubscribed a -> IO Int
• data SomeSwitchSubscribed = forall a . SomeSwitchSubscribed (SwitchSubscribed a)
• debugInvalidate :: Bool
• invalidate :: IORef [SomeSwitchSubscribed] -> WeakList Invalidator -> IO (WeakList Invalidator)
• data Spider
• newtype RootTrigger a = RootTrigger (IORef [WeakSubscriber a], IORef (Maybe a))
• newtype SpiderHost a = SpiderHost {
  • runSpiderHost :: IO a
  }
• newtype SpiderHostFrame a = SpiderHostFrame {
  • runSpiderHostFrame :: EventM a
  }
• newEventWithTriggerIO :: (RootTrigger a -> IO (IO ())) -> IO (Event Spider a)

Documentation