@@ -314,7 +314,7 @@ fromIndicesM gen = go 0
314314fromIndices :: IsStream t => (Int -> a) -> t m a
315315fromIndices gen = go 0
316316 where
317− go n = (gen n) `cons` go (n + 1)
317+ go n = gen n `cons` go (n + 1)
318318
319319{-# INLINE iterate #-}
320320iterate :: IsStream t => (a -> a) -> a -> t m a
@@ -367,7 +367,7 @@ foldr step acc = foldrM (\x xs -> xs >>= \b -> return (step x b)) (return acc)
367367{-# INLINE foldrT #-}
368368foldrT :: (IsStream t, Monad m, Monad (s m), MonadTrans s)
369369 => (a -> s m b -> s m b) -> s m b -> t m a -> s m b
370−foldrT step final m = go m
370+foldrT step final = go
371371 where
372372 go m1 = do
373373 res <- lift $ uncons m1
@@ -394,7 +394,7 @@ foldr1 step m = do
394394{-# INLINABLE foldlMx' #-}
395395foldlMx' :: (IsStream t, Monad m)
396396 => (x -> a -> m x) -> m x -> (x -> m b) -> t m a -> m b
397−foldlMx' step begin done m = go begin m
397+foldlMx' step begin done = go begin
398398 where
399399 go !acc m1 =
400400 let stop = acc >>= done
@@ -431,7 +431,7 @@ foldlM' step begin = foldlMx' step begin return
431431-- | Lazy left fold to a stream.
432432{-# INLINE foldlS #-}
433433foldlS :: IsStream t => (t m b -> a -> t m b) -> t m b -> t m a -> t m b
434−foldlS step begin m = go begin m
434+foldlS step = go
435435 where
436436 go acc rest = mkStream $ \st yld sng stp ->
437437 let run x = foldStream st yld sng stp x
@@ -444,7 +444,7 @@ foldlS step begin m = go begin m
444444{-# INLINE foldlT #-}
445445foldlT :: (IsStream t, Monad m, Monad (s m), MonadTrans s)
446446 => (s m b -> a -> s m b) -> s m b -> t m a -> s m b
447−foldlT step begin m = go begin m
447+foldlT step = go
448448 where
449449 go acc m1 = do
450450 res <- lift $ uncons m1
@@ -588,7 +588,7 @@ mfix f = mkStream $ \st yld sng stp ->
588588
589589{-# INLINE init #-}
590590init :: (IsStream t, Monad m) => t m a -> m (Maybe (t m a))
591−init m = go1 m
591+init = go1
592592 where
593593 go1 m1 = do
594594 r <- uncons m1
@@ -602,7 +602,7 @@ init m = go1 m
602602
603603{-# INLINE elem #-}
604604elem :: (IsStream t, Monad m, Eq a) => a -> t m a -> m Bool
605−elem e m = go m
605+elem e = go
606606 where
607607 go m1 =
608608 let stop = return False
@@ -612,7 +612,7 @@ elem e m = go m
612612
613613{-# INLINE notElem #-}
614614notElem :: (IsStream t, Monad m, Eq a) => a -> t m a -> m Bool
615−notElem e m = go m
615+notElem e = go
616616 where
617617 go m1 =
618618 let stop = return True
@@ -622,7 +622,7 @@ notElem e m = go m
622622
623623{-# INLINABLE all #-}
624624all :: (IsStream t, Monad m) => (a -> Bool) -> t m a -> m Bool
625−all p m = go m
625+all p = go
626626 where
627627 go m1 =
628628 let single a | p a = return True
@@ -633,7 +633,7 @@ all p m = go m
633633
634634{-# INLINABLE any #-}
635635any :: (IsStream t, Monad m) => (a -> Bool) -> t m a -> m Bool
636−any p m = go m
636+any p = go
637637 where
638638 go m1 =
639639 let single a | p a = return True
@@ -649,7 +649,7 @@ last = foldlx' (\_ y -> Just y) Nothing id
649649
650650{-# INLINE minimum #-}
651651minimum :: (IsStream t, Monad m, Ord a) => t m a -> m (Maybe a)
652−minimum m = go Nothing m
652+minimum = go Nothing
653653 where
654654 go Nothing m1 =
655655 let stop = return Nothing
@@ -673,7 +673,7 @@ minimum m = go Nothing m
673673minimumBy
674674 :: (IsStream t, Monad m)
675675 => (a -> a -> Ordering) -> t m a -> m (Maybe a)
676−minimumBy cmp m = go Nothing m
676+minimumBy cmp = go Nothing
677677 where
678678 go Nothing m1 =
679679 let stop = return Nothing
@@ -693,7 +693,7 @@ minimumBy cmp m = go Nothing m
693693
694694{-# INLINE maximum #-}
695695maximum :: (IsStream t, Monad m, Ord a) => t m a -> m (Maybe a)
696−maximum m = go Nothing m
696+maximum = go Nothing
697697 where
698698 go Nothing m1 =
699699 let stop = return Nothing
@@ -715,7 +715,7 @@ maximum m = go Nothing m
715715
716716{-# INLINE maximumBy #-}
717717maximumBy :: (IsStream t, Monad m) => (a -> a -> Ordering) -> t m a -> m (Maybe a)
718−maximumBy cmp m = go Nothing m
718+maximumBy cmp = go Nothing
719719 where
720720 go Nothing m1 =
721721 let stop = return Nothing
@@ -747,7 +747,7 @@ m !! i = go i m
747747
748748{-# INLINE lookup #-}
749749lookup :: (IsStream t, Monad m, Eq a) => a -> t m (a, b) -> m (Maybe b)
750−lookup e m = go m
750+lookup e = go
751751 where
752752 go m1 =
753753 let single (a, b) | a == e = return $ Just b
@@ -758,7 +758,7 @@ lookup e m = go m
758758
759759{-# INLINE findM #-}
760760findM :: (IsStream t, Monad m) => (a -> m Bool) -> t m a -> m (Maybe a)
761−findM p m = go m
761+findM p = go
762762 where
763763 go m1 =
764764 let single a = do
@@ -793,7 +793,7 @@ findIndices p = go 0
793793-- output of the action.
794794{-# INLINE mapM_ #-}
795795mapM_ :: (IsStream t, Monad m) => (a -> m b) -> t m a -> m ()
796−mapM_ f m = go m
796+mapM_ f = go
797797 where
798798 go m1 =
799799 let stop = return ()
@@ -851,7 +851,7 @@ scanl' step begin = scanlx' step begin id
851851
852852{-# INLINE filter #-}
853853filter :: IsStream t => (a -> Bool) -> t m a -> t m a
854−filter p m = go m
854+filter p = go
855855 where
856856 go m1 = mkStream $ \st yld sng stp ->
857857 let single a | p a = sng a
@@ -862,7 +862,7 @@ filter p m = go m
862862
863863{-# INLINE take #-}
864864take :: IsStream t => Int -> t m a -> t m a
865−take n m = go n m
865+take = go
866866 where
867867 go n1 m1 = mkStream $ \st yld sng stp ->
868868 let yieldk a r = yld a (go (n1 - 1) r)
@@ -872,7 +872,7 @@ take n m = go n m
872872
873873{-# INLINE takeWhile #-}
874874takeWhile :: IsStream t => (a -> Bool) -> t m a -> t m a
875−takeWhile p m = go m
875+takeWhile p = go
876876 where
877877 go m1 = mkStream $ \st yld sng stp ->
878878 let single a | p a = sng a
@@ -895,7 +895,7 @@ drop n m = fromStream $ unShare (go n (toStream m))
895895
896896{-# INLINE dropWhile #-}
897897dropWhile :: IsStream t => (a -> Bool) -> t m a -> t m a
898−dropWhile p m = go m
898+dropWhile p = go
899899 where
900900 go m1 = mkStream $ \st yld sng stp ->
901901 let single a | p a = stp
@@ -912,7 +912,7 @@ dropWhile p m = go m
912912-- other stream types to overload it.
913913{-# INLINE sequence #-}
914914sequence :: (IsStream t, MonadAsync m) => t m (m a) -> t m a
915−sequence m = go m
915+sequence = go
916916 where
917917 go m1 = mkStream $ \st yld sng stp ->
918918 let single ma = ma >>= sng
@@ -925,7 +925,7 @@ sequence m = go m
925925
926926{-# INLINE intersperseM #-}
927927intersperseM :: (IsStream t, MonadAsync m) => m a -> t m a -> t m a
928−intersperseM a m = prependingStart m
928+intersperseM a = prependingStart
929929 where
930930 prependingStart m1 = mkStream $ \st yld sng stp ->
931931 let yieldk i x = foldStreamShared st yld sng stp $ return i |: go x
@@ -941,7 +941,7 @@ intersperse a = intersperseM (return a)
941941
942942{-# INLINE insertBy #-}
943943insertBy :: IsStream t => (a -> a -> Ordering) -> a -> t m a -> t m a
944−insertBy cmp x m = go m
944+insertBy cmp x = go
945945 where
946946 go m1 = mkStream $ \st yld _ _ ->
947947 let single a = case cmp x a of
@@ -959,7 +959,7 @@ insertBy cmp x m = go m
959959
960960{-# INLINE deleteBy #-}
961961deleteBy :: IsStream t => (a -> a -> Bool) -> a -> t m a -> t m a
962−deleteBy eq x m = go m
962+deleteBy eq x = go
963963 where
964964 go m1 = mkStream $ \st yld sng stp ->
965965 let single a = if eq x a then stp else sng a
@@ -982,12 +982,10 @@ reverse = foldlS (flip cons) nil
982982
983983{-# INLINE mapMaybe #-}
984984mapMaybe :: IsStream t => (a -> Maybe b) -> t m a -> t m b
985−mapMaybe f m = go m
985+mapMaybe f = go
986986 where
987987 go m1 = mkStream $ \st yld sng stp ->
988− let single a = case f a of
989− Just b -> sng b
990− Nothing -> stp
988+ let single a = maybe stp sng (f a)
991989 yieldk a r = case f a of
992990 Just b -> yld b $ go r
993991 Nothing -> foldStream (adaptState st) yieldk single stp r
@@ -1018,7 +1016,7 @@ zipWith f = go
10181016-- @since 0.1.0
10191017{-# INLINABLE zipWithM #-}
10201018zipWithM :: (IsStream t, Monad m) => (a -> b -> m c) -> t m a -> t m b -> t m c
1021−zipWithM f m1 m2 = go m1 m2
1019+zipWithM f = go
10221020 where
10231021 go mx my = mkStream $ \st yld sng stp -> do
10241022 let merge a ra =