@@ -409,7 +409,7 @@ tap n = composeN n $ S.tap FL.sum
409tapRate :: Int -> Stream IO Int -> IO ()
409tapRate :: Int -> Stream IO Int -> IO ()
410tapRate n str = do
410tapRate n str = do
411 cref <- newIORef 0
411 cref <- newIORef 0
412− composeN n (S.tapRate 1 (\c -> modifyIORef' cref (c +))) str
412+ composeN n (Internal.tapRate 1 (\c -> modifyIORef' cref (c +))) str
414{-# INLINE tapAsyncS #-}
414{-# INLINE tapAsyncS #-}
415tapAsyncS :: S.MonadAsync m => Int -> Stream m Int -> m ()
415tapAsyncS :: S.MonadAsync m => Int -> Stream m Int -> m ()