diff --git a/hbs2-core/lib/HBS2/Actors/Peer.hs b/hbs2-core/lib/HBS2/Actors/Peer.hs index ad63f929..67ebc2fb 100644 --- a/hbs2-core/lib/HBS2/Actors/Peer.hs +++ b/hbs2-core/lib/HBS2/Actors/Peer.hs @@ -451,7 +451,7 @@ runPeerM env@PeerEnv{..} f = flip runContT pure do n <- liftIO getNumCapabilities <&> max 2 . div 2 - as <- liftIO $ replicateM n $ async $ runPipeline _envDeferred + as <- liftIO $ replicateM n $ asyncLinked $ runPipeline _envDeferred sw <- liftIO $ async $ forever $ withPeerM env $ do pause defSweepTimeout