works

hbs2-core/lib/HBS2/Actors/ChunkWriter.hs

@@ -122,8 +122,8 @@ runChunkWriter2 w = do
       amount <- for ks $ \k -> flush w k
 
       if (sum amount == 0) then do
-        pure ()
-        -- pause ( 0.5 :: Timeout 'Seconds )
+        -- pure ()
+        pause ( 0.1 :: Timeout 'Seconds )
       else do
         liftIO $ print ("flushed:" <+> pretty (sum amount))
 

hbs2-core/lib/HBS2/Actors/Peer.hs

@@ -303,7 +303,7 @@ runPeerM s bus p f  = do
                             <*> liftIO (newTVarIO mempty)
 
   let de = view envDeferred env
-  as <- liftIO $ replicateM 8 $ async $ runPipeline de
+  as <- liftIO $ replicateM 4 $ async $ runPipeline de
 
   sw <- liftIO $ async $ forever $ withPeerM env $ do
           pause defSweepTimeout

hbs2-tests/test/Peer2Main.hs

@@ -155,7 +155,7 @@ runTestPeer p zu = do
   cww  <- newChunkWriterIO  stor (Just chDir)
 
   sw <- liftIO $ replicateM 4  $ async $ simpleStorageWorker stor
-  cw <- liftIO $ replicateM 8 $ async $ runChunkWriter cww
+  cw <- liftIO $ replicateM 8  $ async $ runChunkWriter cww
 
   zu stor cww