mirror of
https://github.com/simplex-chat/simplexmq.git
synced 2026-03-30 20:45:52 +00:00
revert to using forkIO in the tests
This commit is contained in:
@@ -123,7 +123,7 @@ cfg =
|
||||
withSmpAgentThreadOn :: (MonadUnliftIO m, MonadRandom m) => (ServiceName, String) -> (ThreadId -> m a) -> m a
|
||||
withSmpAgentThreadOn (port', db') =
|
||||
E.bracket
|
||||
(forkIOWithUnmask ($ runSMPAgent cfg {tcpPort = port', dbFile = db'}))
|
||||
(forkIO $ runSMPAgent cfg {tcpPort = port', dbFile = db'})
|
||||
(liftIO . killThread >=> const (removeFile db'))
|
||||
|
||||
withSmpAgentOn :: (MonadUnliftIO m, MonadRandom m) => (ServiceName, String) -> m a -> m a
|
||||
|
||||
@@ -43,7 +43,7 @@ cfg =
|
||||
withSmpServerThreadOn :: (MonadUnliftIO m, MonadRandom m) => ServiceName -> (ThreadId -> m a) -> m a
|
||||
withSmpServerThreadOn port =
|
||||
E.bracket
|
||||
(forkIOWithUnmask ($ runSMPServer cfg {tcpPort = port}))
|
||||
(forkIO $ runSMPServer cfg {tcpPort = port})
|
||||
(liftIO . killThread)
|
||||
|
||||
withSmpServerOn :: (MonadUnliftIO m, MonadRandom m) => ServiceName -> m a -> m a
|
||||
|
||||
Reference in New Issue
Block a user