avoid dropping upstream items in mergeSource

snoyberg · Aug 26, 2024 · ab68cdc · ab68cdc
1 parent 5f2ad8a
commit ab68cdc
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/conduit/src/Data/Conduit/Internal/Conduit.hs b/conduit/src/Data/Conduit/Internal/Conduit.hs
@@ -613,7 +613,7 @@ mergeSource = loop . sealConduitT
         go a = do
           (src1, mi) <- lift $ src0 $$++ await
           case mi of
-            Nothing -> return ()
+            Nothing -> leftover a
             Just i  -> yield (i, a) >> loop src1