fix(journal): add sleep to avoid spin loop on macos

platonic-io · Mar 21, 2022 · 9c274b0 · 9c274b0
1 parent b5cf732
commit 9c274b0
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/journal/src/Journal/MP.hs b/src/journal/src/Journal/MP.hs
@@ -217,6 +217,7 @@ readManyJournalSC jour sub state0 process = do
                  state' <- process state bs
                  incrBytesConsumed_ (jMetadata jour) sub
                    (align (int322Int len) fRAME_ALIGNMENT)
+                 threadDelay 1
                  go (steps + 1) (offset + align (int322Int len) fRAME_ALIGNMENT) position state'
 
 readManyLazyJournalSC :: forall s. Journal -> Subscriber -> s -> (s -> LBS.ByteString -> IO s)