process-streaming 0.9.1.2 → 0.9.2

raw patch · 3 files changed

+33/−40 lines, 3 filesdep ~pipes-transduce

Dependency ranges changed: pipes-transduce

Files

• CHANGELOG +5/−0
• process-streaming.cabal +9/−6
• src/System/Process/Streaming/Text.hs +19/−34

@@ -1,3 +1,8 @@+0.9.2.0+-------+- Bumped pipes-transduce dependency to 0.4.1.+- New functions like next and throwE reexported from Pipes.Transduce.+ 0.9.1.0 ------- - Added executeInteractive and executeInteractiveFallibly

@@ -1,9 +1,9 @@ name:          process-streaming-version:       0.9.1.2+version:       0.9.2 license:       BSD3 license-file:  LICENSE data-files:    -author:        Daniel Díaz Carrete+author:        Daniel Diaz Carrete maintainer:    diaz_carrete@yahoo.com category:      System build-type:    Simple@@ -24,7 +24,7 @@         System.Process.Streaming.Text         System.Process.Lens     other-modules: -    ghc-options: -Wall -threaded -O2+    ghc-options: -Wall -O2     build-depends:                  base >= 4.4 && < 5       , process >= 1.2.3.0@@ -43,7 +43,7 @@       , pipes-concurrency >= 2.0.2       , pipes-bytestring >=2.1.0       , pipes-text >= 0.0.0.10-      , pipes-transduce >= 0.3.3.0+      , pipes-transduce >= 0.4.1       , conceit >= 0.3.2.0  Test-suite test@@ -75,7 +75,7 @@       , pipes-text >= 0.0.0.10       , pipes-group >= 1.0.1       , pipes-attoparsec >= 0.5-      , pipes-transduce >= 0.3.3.0+      , pipes-transduce >= 0.4.1       , exceptions >= 0.6.0 && < 1.0       , semigroups >= 0.15 && < 0.20       , containers >= 0.4@@ -87,6 +87,8 @@       , process-streaming  test-suite doctests+  default-language:+      Haskell2010   type:           exitcode-stdio-1.0   ghc-options:    -Wall -threaded   hs-source-dirs: tests@@ -111,7 +113,7 @@       , pipes-text >= 0.0.0.10       , pipes-group >= 1.0.1       , pipes-attoparsec >= 0.5-      , pipes-transduce >= 0.3.3.0+      , pipes-transduce >= 0.4.1       , exceptions >= 0.6.0        , semigroups >= 0.15        , containers >= 0.4@@ -123,6 +125,7 @@       , tasty >= 0.9       , tasty-hunit >= 0.9       , process-streaming+  default-language: Haskell2010  Source-repository head     type:     git

@@ -31,60 +31,45 @@  {- $examples -   To process a standard stream as text, use the 'utf8' or 'utf8x'-   'Transducer's, applying them with 'transduce1' to a 'Fold1' that accepts-   text. -   -   The result will be a a 'Fold1' that accepts raw 'ByteStrings':+   To process a standard stream as utf8 text: ->>> execute (piped (shell "echo foo")) (foldOut (transduce1 PT.utf8x PT.intoLazyText))+>>> execute (piped (shell "echo foo")) (foldOut (PT.asUtf8x PT.intoLazyText)) "foo\n"    -   The difference between 'utf8' and 'utf8x' is that the former uses an 'Either'-   to signal encoding errors, while the latter uses an exception.+   'Pipes.Transduce.Text.asUtf8x' throws exceptions on decodign errors.+   'Pipes.Transduce.Text.asUtf8' uses sum types instead. We must provide an+   error mapping function, here we simply use 'id': ->>> executeFallibly (piped (shell "echo foo")) (foldOut (transduce1 PT.utf8 PT.intoLazyText))+>>> executeFallibly (piped (shell "echo foo")) (foldOut (PT.asUtf8 id PT.intoLazyText)) Right "foo\n"       -   'foldedLines' lets you consume the lines that appear in a stream as lazy-   'Data.Text.Lazy.Text's. Here we collect them in a list using the-   'Control.Foldl.list' 'Control.Foldl.Fold' from the @foldl@ package:+   'Pipes.Transduce.Text.asFoldedLines' lets you identify and consume the lines that appear in a+   stream as lazy 'Data.Text.Lazy.Text's.  >>> :{ -      execute (piped (shell "{ echo foo ; echo bar ; }"))-    . foldOut-    . transduce1 PT.utf8x -    . transduce1 PT.foldedLines -    $ withFold L.list+      execute (piped (shell "{ echo foo ; echo bar ; }")) $+          (foldOut (PT.asUtf8x (PT.asFoldedLines intoList)))     :} ["foo","bar"]      Sometimes we want to consume the lines in @stdout@ and @stderr@ as a single-    stream. We can do this with 'System.Process.Streaming.foldOutErr' and the 'Pipes.Transduce.combined' function.+    text stream. We can do this with 'System.Process.Streaming.foldOutErr' and+    'Pipes.Transduce.Text.combinedLines'. -    'combined' takes one 'Pipes.Transduce.Transducer' for @stdout@ and another-    for @stderr@, that know how to decode each stream into text, then break-    the text into lines.  -    -    The resulting lines are consumed using a 'Fold1': +    We also need 'Pipes.Transduce.Text.bothAsUtf8x' to decode both streams.  >>> :{ -      execute (piped (shell "{ echo ooo ; sleep 1 ; echo eee 1>&2 ; }"))  -    . foldOutErr-    . combined (PT.lines PT.utf8x) (PT.lines PT.utf8x)-    $ intoLazyText+      execute (piped (shell "{ echo ooo ; sleep 1 ; echo eee 1>&2 ; }")) $ +          (foldOutErr (PT.bothAsUtf8x (PT.combinedLines PT.intoLazyText)))     :} "ooo\neee\n" -    We can also tag each line with its provenance, using 'Pipes.Transduce.groups':+    We can also tag each line with its provenance, using+    'Pipes.Transduce.Text.combinedLinesPrefixing':  >>> :{ -    let tag prefix = groups (\producer -> Pipes.yield prefix *> producer)-    in-      execute (piped (shell "{ echo ooo ; sleep 1 ; echo eee 1>&2 ; }"))  -    . foldOutErr-    . combined (tag "+" (PT.lines PT.utf8x)) (tag "-" (PT.lines PT.utf8x))-    $ intoLazyText+      execute (piped (shell "{ echo ooo ; sleep 1 ; echo eee 1>&2 ; }")) $+          (foldOutErr (PT.bothAsUtf8x (PT.combinedLinesPrefixing "+" "-" PT.intoLazyText)))     :} "+ooo\n-eee\n"