dandri/simplexmq
1
0
Fork 0
mirror of https://github.com/simplex-chat/simplexmq.git synced 2026-05-28 16:14:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor

Browse Source
This commit is contained in:
Evgeny Poberezkin
2024-08-09 11:01:32 +01:00
parent b9654fad31
commit e10cec4c94
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Simplex/Messaging/Agent/Client.hs
+8 -8
View File
@@ -1871,20 +1871,20 @@ agentOperationBracket c op check action =
(const action)
waitUntilForeground :: AgentClient -> IO ()
waitUntilForeground AgentClient {agentState} =
unlessM (foreground $ readTVarIO agentState) $ atomically $ unlessM (foreground $ readTVar agentState) retry
waitUntilForeground c =
unlessM (foreground readTVarIO) $ atomically $ unlessM (foreground readTVar) retry
where
foreground :: Monad m => m AgentState -> m Bool
foreground = fmap (ASForeground ==)
foreground :: Monad m => (TVar AgentState -> m AgentState) -> m Bool
foreground rd = (ASForeground ==) <$> rd (agentState c)
-- This function waits while agent is suspended, but will proceed while it is suspending,
-- to allow completing in-flight operations.
waitWhileSuspended :: AgentClient -> IO ()
waitWhileSuspended AgentClient {agentState} =
whenM (suspended $ readTVarIO agentState) $ atomically $ whenM (suspended $ readTVar agentState) retry
waitWhileSuspended c =
whenM (suspended readTVarIO) $ atomically $ whenM (suspended readTVar) retry
where
suspended :: Monad m => m AgentState -> m Bool
suspended = fmap (ASSuspended ==)
suspended :: Monad m => (TVar AgentState -> m AgentState) -> m Bool
suspended rd = (ASSuspended ==) <$> rd (agentState c)
withStore' :: AgentClient -> (DB.Connection -> IO a) -> AM a
withStore' c action = withStore c $ fmap Right . action