@@ -511,15 +511,13 @@ module Streamly.Data.Stream
511511 , runReaderT
512512 , runStateT
513513
514+ -- XXX Arrays could be different types, therefore, this should be in
515+ -- specific array module. Or maybe we should abstract over array types.
514516 -- * Stream of Arrays
515517 , Array.chunksOf
516− , chunksSplitOn
517518 )
518519where
519520
520−import Control.Monad.IO.Class (MonadIO)
521−import Data.Word (Word8)
522−import Streamly.Data.Array (Array)
523521import Streamly.Internal.Data.Stream
524522import Prelude
525523 hiding (filter, drop, dropWhile, take, takeWhile, zipWith, foldr,
@@ -529,7 +527,6 @@ import Prelude
529527 scanl, scanl1, repeat, replicate, concatMap, span)
530528
531529import qualified Streamly.Internal.Data.Array.Type as Array
532−import qualified Streamly.Internal.Data.Stream.Chunked as ArrayStream
533530
534531#include "DocTestDataStream.hs"
535532
@@ -638,14 +635,3 @@ import qualified Streamly.Internal.Data.Stream.Chunked as ArrayStream
638635--
639636-- 'Stream' and 'StreamK' types can be interconverted. See
640637-- "Streamly.Data.StreamK" module for conversion operations.
641−
642−-- | Split a stream of arrays on a given separator byte, dropping the separator
643−-- and coalescing all the arrays between two separators into a single array.
644−--
645−{-# INLINE chunksSplitOn #-}
646−chunksSplitOn
647− :: (MonadIO m)
648− => Word8
649− -> Stream m (Array Word8)
650− -> Stream m (Array Word8)
651−chunksSplitOn = ArrayStream.splitOn