fixup! Fix a bug in parDistributeScan and block on buffer in sendToWorker_

Author: adithyaov

src/Streamly/Internal/Data/Scanl/Concurrent.hs

@@ -242,8 +242,7 @@ parDistributeScan cfg getFolds (Stream sstep state) =
                 then do
                     liftIO $ takeMVar db
                     return $ Skip (ScanDrain q db running)
-                else return $ Yield outputs ScanStop
-
+                else return $ Yield outputs (ScanDrain q db running)
     step _ ScanStop = return Stop
 
 {-# ANN type DemuxState Fuse #-}