git.iko.soy/streamly
on master help sign in
Do not lose stream state in ahead stream
37452d9Harendra Kumar
src/Streamly/Internal/Data/Stream/Ahead.hs+3−3
compare with master
unifiedsplit
@@ -300,7 +300,7 @@ processHeap q heap st sv winfo entry sno stopping = loopHeap sno entry
300 let stop = do
300 let stop = do
301 liftIO (incrementYieldLimit sv)
301 liftIO (incrementYieldLimit sv)
302 nextHeap seqNo
302 nextHeap seqNo
303− foldStreamSVar sv st
303+ foldStreamShared st
304 (yieldStreamFromHeap seqNo)
304 (yieldStreamFromHeap seqNo)
305 (singleStreamFromHeap seqNo)
305 (singleStreamFromHeap seqNo)
306 stop
306 stop
@@ -437,7 +437,7 @@ processWithToken q heap st sv winfo action sno = do
437 let stop = do
437 let stop = do
438 liftIO (incrementYieldLimit sv)
438 liftIO (incrementYieldLimit sv)
439 loopWithToken (seqNo + 1)
439 loopWithToken (seqNo + 1)
440− foldStreamSVar sv st
440+ foldStreamShared st
441 (yieldOutput seqNo)
441 (yieldOutput seqNo)
442 (singleOutput seqNo)
442 (singleOutput seqNo)
443 stop
443 stop
@@ -468,7 +468,7 @@ processWithToken q heap st sv winfo action sno = do
468 let stop = do
468 let stop = do
469 liftIO (incrementYieldLimit sv)
469 liftIO (incrementYieldLimit sv)
470 loopWithToken (seqNo + 1)
470 loopWithToken (seqNo + 1)
471− foldStreamSVar sv st
471+ foldStreamShared st
472 (yieldOutput seqNo)
472 (yieldOutput seqNo)
473 (singleOutput seqNo)
473 (singleOutput seqNo)
474 stop
474 stop