Safe Haskell	None
Language	Haskell2010

Reflex.Process.Lines

Contents

Output lines

Synopsis

data Lines = Lines {
- _lines_terminated :: Seq ByteString
- _lines_unterminated :: Maybe ByteString
}
emptyLines :: Lines
addLines :: ByteString -> Lines -> Lines
linesFromBS :: ByteString -> Lines
unLines :: Lines -> ByteString
lastWholeLine :: Lines -> Maybe ByteString
splitLinesOn :: (ByteString -> Bool) -> Lines -> Maybe (Lines, Lines)
newLines :: (Reflex t, MonadHold t m, MonadFix m) => Event t ByteString -> Event t () -> m (Event t Lines)

Output lines

data Lines Source #

Accumulator for line-based output that keeps track of any dangling, unterminated line

Constructors

Lines
Fields _lines_terminated :: Seq ByteString _lines_unterminated :: Maybe ByteString

Instances

Instances details

Eq Lines Source #
Instance details Defined in Reflex.Process.Lines Methods (==) :: Lines -> Lines -> Bool Source # (/=) :: Lines -> Lines -> Bool Source #
Ord Lines Source #
Instance details Defined in Reflex.Process.Lines Methods compare :: Lines -> Lines -> Ordering Source # (<) :: Lines -> Lines -> Bool Source # (<=) :: Lines -> Lines -> Bool Source # (>) :: Lines -> Lines -> Bool Source # (>=) :: Lines -> Lines -> Bool Source # max :: Lines -> Lines -> Lines Source # min :: Lines -> Lines -> Lines Source #
Read Lines Source #
Instance details Defined in Reflex.Process.Lines Methods readsPrec :: Int -> ReadS Lines Source # readList :: ReadS [Lines] Source # readPrec :: ReadPrec Lines Source # readListPrec :: ReadPrec [Lines] Source #
Show Lines Source #
Instance details Defined in Reflex.Process.Lines Methods showsPrec :: Int -> Lines -> ShowS Source # show :: Lines -> String Source # showList :: [Lines] -> ShowS Source #
Semigroup Lines Source #
Instance details Defined in Reflex.Process.Lines Methods (<>) :: Lines -> Lines -> Lines Source # sconcat :: NonEmpty Lines -> Lines Source # stimes :: Integral b => b -> Lines -> Lines Source #
Monoid Lines Source #
Instance details Defined in Reflex.Process.Lines Methods mempty :: Lines Source # mappend :: Lines -> Lines -> Lines Source # mconcat :: [Lines] -> Lines Source #

emptyLines :: Lines Source #

Empty output

addLines :: ByteString -> Lines -> Lines Source #

Add some raw output to a Lines. This will chop the raw output up into lines.

linesFromBS :: ByteString -> Lines Source #

Convert a ByteString into a Lines

unLines :: Lines -> ByteString Source #

Convert a Lines back into a ByteString

lastWholeLine :: Lines -> Maybe ByteString Source #

Convenience accessor for the last whole line received by a Lines. Ignores any unterminated line that may follow.

splitLinesOn :: (ByteString -> Bool) -> Lines -> Maybe (Lines, Lines) Source #

Split lines into two. The sequence that satisfies the predicate is consumed and will not appear in either resulting Lines.

newLines Source #

Arguments

:: (Reflex t, MonadHold t m, MonadFix m)
=> Event t ByteString
-> Event t ()	Event that flushes any remaining unterminated lines
-> m (Event t Lines)	These will be complete lines except when the flush event fires, in which it may include unterminated lines

Given an event of raw bytes, fire an output event of *terminated* lines. Unterminated lines are held until the line they belong to is completed or until the flush event fires.