@@ -692,50 +692,66 @@ main = hspec
693 let makeOps t =
693 let makeOps t =
695+#ifndef COVERAGE_BUILD
695 , t . maxRate 0
696 , t . maxRate 0
696 , t . maxRate (-1)
697 , t . maxRate (-1)
697 , t . maxBuffer 0
698 , t . maxBuffer 0
698−#ifndef COVERAGE_BUILD
699 , t . maxBuffer 1
699 , t . maxBuffer 1
701 , t . maxThreads 0
700 , t . maxThreads 0
702 , t . maxThreads 1
701 , t . maxThreads 1
703 , t . maxThreads (-1)
702 , t . maxThreads (-1)
706 let serialOps :: IsStream t => ((SerialT IO a -> t IO a) -> Spec) -> Spec
706 let serialOps :: IsStream t => ((SerialT IO a -> t IO a) -> Spec) -> Spec
707 serialOps = forM_ $ (makeOps serially)
707 serialOps = forM_ $ (makeOps serially)
708+#ifndef COVERAGE_BUILD
708 ++ [serially . maxRate 0.00000001]
709 ++ [serially . maxRate 0.00000001]
709 ++ [serially . maxBuffer (-1)]
710 ++ [serially . maxBuffer (-1)]
710 let wSerialOps :: IsStream t => ((WSerialT IO a -> t IO a) -> Spec) -> Spec
712 let wSerialOps :: IsStream t => ((WSerialT IO a -> t IO a) -> Spec) -> Spec
711 wSerialOps = forM_ $ makeOps wSerially
713 wSerialOps = forM_ $ makeOps wSerially
714+#ifndef COVERAGE_BUILD
712 ++ [wSerially . maxRate 0.00000001]
715 ++ [wSerially . maxRate 0.00000001]
713 ++ [wSerially . maxBuffer (-1)]
716 ++ [wSerially . maxBuffer (-1)]
714 let asyncOps :: IsStream t => ((AsyncT IO a -> t IO a) -> Spec) -> Spec
718 let asyncOps :: IsStream t => ((AsyncT IO a -> t IO a) -> Spec) -> Spec
715 asyncOps = forM_ $ makeOps asyncly
719 asyncOps = forM_ $ makeOps asyncly
720+#ifndef COVERAGE_BUILD
716 ++ [asyncly . maxRate 10000]
721 ++ [asyncly . maxRate 10000]
717 ++ [asyncly . maxBuffer (-1)]
722 ++ [asyncly . maxBuffer (-1)]
718 let wAsyncOps :: IsStream t => ((WAsyncT IO a -> t IO a) -> Spec) -> Spec
724 let wAsyncOps :: IsStream t => ((WAsyncT IO a -> t IO a) -> Spec) -> Spec
719 wAsyncOps = forM_ $ makeOps wAsyncly
725 wAsyncOps = forM_ $ makeOps wAsyncly
726+#ifndef COVERAGE_BUILD
720 ++ [wAsyncly . maxRate 10000]
727 ++ [wAsyncly . maxRate 10000]
721 ++ [wAsyncly . maxBuffer (-1)]
728 ++ [wAsyncly . maxBuffer (-1)]
722 let aheadOps :: IsStream t => ((AheadT IO a -> t IO a) -> Spec) -> Spec
730 let aheadOps :: IsStream t => ((AheadT IO a -> t IO a) -> Spec) -> Spec
723 aheadOps = forM_ $ makeOps aheadly
731 aheadOps = forM_ $ makeOps aheadly
732+#ifndef COVERAGE_BUILD
724 ++ [aheadly . maxRate 10000]
733 ++ [aheadly . maxRate 10000]
725 ++ [aheadly . maxBuffer (-1)]
734 ++ [aheadly . maxBuffer (-1)]
726 let parallelOps :: IsStream t => ((ParallelT IO a -> t IO a) -> Spec) -> Spec
736 let parallelOps :: IsStream t => ((ParallelT IO a -> t IO a) -> Spec) -> Spec
727 parallelOps = forM_ $ makeOps parallely
737 parallelOps = forM_ $ makeOps parallely
738+#ifndef COVERAGE_BUILD
728 ++ [parallely . maxRate 0.00000001]
739 ++ [parallely . maxRate 0.00000001]
729 ++ [parallely . maxBuffer (-1)]
740 ++ [parallely . maxBuffer (-1)]
730 let zipSerialOps :: IsStream t => ((ZipSerialM IO a -> t IO a) -> Spec) -> Spec
742 let zipSerialOps :: IsStream t => ((ZipSerialM IO a -> t IO a) -> Spec) -> Spec
731 zipSerialOps = forM_ $ makeOps zipSerially
743 zipSerialOps = forM_ $ makeOps zipSerially
744+#ifndef COVERAGE_BUILD
732 ++ [zipSerially . maxRate 0.00000001]
745 ++ [zipSerially . maxRate 0.00000001]
733 ++ [zipSerially . maxBuffer (-1)]
746 ++ [zipSerially . maxBuffer (-1)]
734 -- Note, the "pure" of applicative Zip streams generates and infinite
748 -- Note, the "pure" of applicative Zip streams generates and infinite
735 -- stream and therefore maxBuffer (-1) must not be used for that case.
749 -- stream and therefore maxBuffer (-1) must not be used for that case.
736 let zipAsyncOps :: IsStream t => ((ZipAsyncM IO a -> t IO a) -> Spec) -> Spec
750 let zipAsyncOps :: IsStream t => ((ZipAsyncM IO a -> t IO a) -> Spec) -> Spec
737 zipAsyncOps = forM_ $ makeOps zipAsyncly
751 zipAsyncOps = forM_ $ makeOps zipAsyncly
752+#ifndef COVERAGE_BUILD
738 ++ [zipAsyncly . maxRate 10000]
753 ++ [zipAsyncly . maxRate 10000]
740 describe "Construction" $ do
756 describe "Construction" $ do
741 serialOps $ prop "serially replicateM" . constructWithReplicateM
757 serialOps $ prop "serially replicateM" . constructWithReplicateM
@@ -883,11 +899,13 @@ main = hspec
883 -- exclude those cases from these.
899 -- exclude those cases from these.
884 let mkOps t =
900 let mkOps t =
902+#ifndef COVERAGE_BUILD
886 , t . maxRate 0
903 , t . maxRate 0
887 , t . maxRate (-1)
904 , t . maxRate (-1)
888 , t . maxBuffer 0
905 , t . maxBuffer 0
889 , t . maxThreads 0
906 , t . maxThreads 0
890 , t . maxThreads (-1)
907 , t . maxThreads (-1)
893 describe "Stream concurrent operations" $ do
911 describe "Stream concurrent operations" $ do