unfold.hs

unfoldViaBS' :: Applicative m => Streamly.Unfold.Unfold m BL.ByteString BL.ByteString
unfoldViaBS' = Streamly.Unfold.unfoldr inner
  where
    {-# INLINE inner #-}
    inner input'
      | BL.null input' = Nothing
      | otherwise =
          case BL.elemIndex _lf input' of
            Nothing -> Just (input', BL.empty)
            Just i ->
              let (prefix, suffix) = BL.splitAt i input'
              in Just (prefix, BL.drop 1 suffix)
{-# INLINE unfoldViaBS' #-}

unfoldViaBS :: MonadIO m => Streamly.Unfold.Unfold m IO.Handle Text
unfoldViaBS = fmap (Text.decodeUtf8 . BL.toStrict) $ Streamly.Unfold.lmapM (liftIO . BL.hGetContents) unfoldViaBS'
{-# INLINE unfoldViaBS #-}