Modulestreamly-core-0.3.1Haskell2010

Streamly.Internal.Data.Array.Generic

Contents

Parsing Stream of Arrays

Synopsis

value chunksOf
value create
value createOf
value createOfLast
value createWith
value dropAround
value fold
value foldl'
value foldr
value fromByteStr#
value fromCString#
value fromList
value fromListN
value fromPureStream
value fromStream
value fromStreamN
value getIndex
value getIndexUnsafe
value getSliceUnsafe
value length
value nil
value read
value readRev
value reader
value streamFold
value strip
value toList
value toParserK
value unsafeFreeze
value unsafeGetIndex
value unsafeSliceOffLen
value unsafeThaw
value write
value writeN
data Array
value parse
value parsePos
value parseBreak
value parseBreakPos

Packagestreamly-core-0.3.1
Exports39
LanguageHaskell2010
LicenceBSD-3-Clause
SourceType.hs

valuechunksOf :: MonadIO m => Int -> Stream m a -> Stream m (Array a)

valuecreate :: MonadIO m => Fold m a (Array a)

Source#

Fold the whole input to a single array.

Caution! Do not use this on infinite streams.

valuecreateOf :: MonadIO m => Int -> Fold m a (Array a)

valuecreateOfLast :: MonadIO m => Int -> Fold m a (Array a)

valuecreateWith :: MonadIO m => Int -> Fold m a (Array a)

valuedropAround :: (a -> Bool) -> Array a -> Array a

Source#

Truncate the array at the beginning and end as long as the predicate holds true. Returns a slice of the original array.

valuefold :: Monad m => Fold m a b -> Array a -> m b

valuefoldl' :: (b -> a -> b) -> b -> Array a -> b

valuefoldr :: (a -> b -> b) -> b -> Array a -> b

valuefromByteStr# :: Addr# -> Array Word8

Deprecated. Please use 'unsafePerformIO . fromCString#' instead

valuefromCString# :: MonadIO m => Addr# -> m (Array Word8)

valuefromList :: [a] -> Array a

valuefromListN :: Int -> [a] -> Array a

valuefromPureStream :: Stream Identity a -> Array a

valuefromStream :: MonadIO m => Stream m a -> m (Array a)

valuefromStreamN :: MonadIO m => Int -> Stream m a -> m (Array a)

valuegetIndex :: Int -> Array a -> Maybe a

Source#

Lookup the element at the given index. Index starts from 0.

valuegetIndexUnsafe :: Int -> Array a -> a

Source#

Deprecated. Please use unsafeGetIndex instead.

O(1) Lookup the element at the given index. Index starts from 0. Does not check the bounds.

valuegetSliceUnsafe :: Int -> Int -> Array a -> Array a

Deprecated. Please use unsafeSliceOffLen instead.

valuelength :: Array a -> Int

valuenil :: Array a

valueread :: Monad m => Array a -> Stream m a

valuereadRev :: Monad m => Array a -> Stream m a

valuereader :: Monad m => Unfold m (Array a) a

valuestreamFold :: Monad m => (Stream m a -> m b) -> Array a -> m b

valuestrip :: (a -> Bool) -> Array a -> Array a

Source#

Deprecated. Please use dropAround instead.

Truncate the array at the beginning and end as long as the predicate holds true. Returns a slice of the original array.

valuetoList :: Array a -> [a]

valuetoParserK :: Monad m => Parser a m b -> ParserK (Array a) m b

Source#

Convert a Parser to ParserK working on generic Array stream.

Pre-release

valueunsafeFreeze :: MutArray a -> Array a

valueunsafeGetIndex :: Int -> Array a -> a

Source#

O(1) Lookup the element at the given index. Index starts from 0. Does not check the bounds.

valueunsafeSliceOffLen :: Int -> Int -> Array a -> Array a

valueunsafeThaw :: Array a -> MutArray a

valuewrite :: MonadIO m => Fold m a (Array a)

Deprecated. Please use create instead.

valuewriteN :: MonadIO m => Int -> Fold m a (Array a)

Deprecated. Please use createOf instead.

datadata Array a

Constructors

Array
- arrContents# :: MutableArray# RealWorld a
  The internal contents of the array representing the entire array.
- arrStart :: !Int
  The starting index of this slice.
- arrEnd :: !Int
  First invalid index of the array.

Instances4Eq, Ord, Read, Show

Eq a => Eq (Array a)Defined in streamly-core-0.3.1 · Streamly.Internal.Data.Array.Generic.Type
Ord a => Ord (Array a)Defined in streamly-core-0.3.1 · Streamly.Internal.Data.Array.Generic.Type
Read a => Read (Array a)Defined in streamly-core-0.3.1 · Streamly.Internal.Data.Array.Generic.Type
Show a => Show (Array a)Defined in streamly-core-0.3.1 · Streamly.Internal.Data.Array.Generic.Type

Parsing Stream of Arrays

valueparse

:: Monad m
=> ParserK (Array a) m b
-> StreamK m (Array a)
-> m (Either ParseError b)

valueparsePos

:: Monad m
=> ParserK (Array a) m b
-> StreamK m (Array a)
-> m (Either ParseErrorPos b)

valueparseBreak

:: Monad m
=> ParserK (Array a) m b
-> StreamK m (Array a)
-> m (Either ParseError b, StreamK m (Array a))

valueparseBreakPos

:: Monad m
=> ParserK (Array a) m b
-> StreamK m (Array a)
-> m (Either ParseErrorPos b, StreamK m (Array a))

Source#

Like parseBreak but includes stream position information in the error messages.