Pipes.Csv

This module allows constant-space CSV parsing.

It feeds ByteStrings into cassavas incremental CSV parser to attain true constant-space record streaming.

Documentation

feedParser :: Monad m => Parser a -> Producer ByteString m () -> Producer (Either String a) m ()

Create a Record Producer by feeding ByteStrings into a Parser

feedHeaderParser :: (Monad m, FromNamedRecord a) => HeaderParser (Parser a) -> Producer ByteString m () -> Producer (Either String a) m ()

Create a NamedRecord Producer by feeding ByteStrings into a Parser

decode :: (Monad m, FromRecord a) => Bool -> Producer ByteString m () -> Producer (Either String a) m ()

Equivalent to decodeWith defaultDecodeOptions.

decodeWith :: (Monad m, FromRecord a) => DecodeOptions -> Bool -> Producer ByteString m () -> Producer (Either String a) m ()

Create a Producer that takes a ByteString Producer as input, producing either errors or FromRecords.

decodeByName :: (Monad m, FromNamedRecord a) => Producer ByteString m () => Producer (Either String a) m ()

Equivalent to decodeByNameWith defaultDecodeOptions.

decodeByNameWith :: (Monad m, FromNamedRecord a) => DecodeOptions -> Producer ByteString m () -> Producer (Either String a) m ()

Create a Producer that takes a ByteString Producer as input, producing either errors or FromNamedRecords.