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

restore concurrently_

Browse Source
This commit is contained in:
Alexander Bondarenko
2024-05-30 17:44:15 +03:00
parent 1b183776b6
commit fc48a5f545
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tests/AgentTests/FunctionalAPITests.hs
+6 -4
View File
@@ -1322,8 +1322,9 @@ testRatchetSyncSuspendForeground t = do
foregroundAgent bob2
withSmpServerStoreMsgLogOn t testPort $ \_ -> do
get alice =##> ratchetSyncP bobId RSAgreed
get bob2 =##> ratchetSyncP aliceId RSAgreed
concurrently_
(get alice =##> ratchetSyncP bobId RSAgreed)
(get bob2 =##> ratchetSyncP aliceId RSAgreed)
get alice =##> ratchetSyncP bobId RSOk
get bob2 =##> ratchetSyncP aliceId RSOk
runRight_ $ exchangeGreetingsMsgIds alice bobId 12 bob2 aliceId 9
@@ -1348,8 +1349,9 @@ testRatchetSyncSimultaneous t = do
liftIO $ aRSS `shouldBe` RSStarted
withSmpServerStoreMsgLogOn t testPort $ \_ -> do
get alice =##> ratchetSyncP bobId RSAgreed
get bob2 =##> ratchetSyncP aliceId RSAgreed
concurrently_
(get alice =##> ratchetSyncP bobId RSAgreed)
(get bob2 =##> ratchetSyncP aliceId RSAgreed)
get alice =##> ratchetSyncP bobId RSOk
get bob2 =##> ratchetSyncP aliceId RSOk
runRight_ $ exchangeGreetingsMsgIds alice bobId 12 bob2 aliceId 9