conduit-extra 1.3.6 → 1.3.8

raw patch · 4 files changed

Files

• ChangeLog.md +8/−0
• Data/Conduit/Process.hs +11/−2
• conduit-extra.cabal +3/−4
• test/Data/Conduit/ProcessSpec.hs +9/−0

@@ -1,5 +1,13 @@ # ChangeLog for conduit-extra +## 1.3.8++* Gracefully handle when a subprocess started using `Data.Conduit.Process.sourceProcessWithStreams` closes its stdin. Fixes [#523](https://github.com/snoyberg/conduit/issues/523)++## 1.3.7++* Allow Data.Conduit.Network.Unix on Windows [#518](https://github.com/snoyberg/conduit/pull/518)+ ## 1.3.6  * Add support for `transformers-0.6`

@@ -39,7 +39,8 @@ import Data.ByteString (ByteString) import Data.ByteString.Builder (Builder) import Control.Concurrent.Async (runConcurrently, Concurrently(..))-import Control.Exception (onException, throwIO, finally, bracket)+import Control.Exception (onException, throwIO, finally, bracket, catch)+import System.IO.Error (ioeGetErrorType, isResourceVanishedErrorType) #if (__GLASGOW_HASKELL__ < 710) import Control.Applicative ((<$>), (<*>)) #endif@@ -143,16 +144,24 @@      , (sourceStdout, closeStdout)      , (sourceStderr, closeStderr)      , sph) <- streamingProcess cp+    let safeSinkStdin = sinkStdin `catchC` ignoreStdinClosed+        safeCloseStdin = closeStdin `catch` ignoreStdinClosed     (_, resStdout, resStderr) <-       runConcurrently (         (,,)-        <$> Concurrently ((unliftIO u $ runConduit $ producerStdin .| sinkStdin) `finally` closeStdin)+        <$> Concurrently ((unliftIO u $ runConduit $ producerStdin .| safeSinkStdin) `finally` safeCloseStdin)         <*> Concurrently (unliftIO u $ runConduit $ sourceStdout .| consumerStdout)         <*> Concurrently (unliftIO u $ runConduit $ sourceStderr .| consumerStderr))       `finally` (closeStdout >> closeStderr)       `onException` terminateStreamingProcess sph     ec <- waitForStreamingProcess sph     return (ec, resStdout, resStderr)+  where+    ignoreStdinClosed :: forall m. (MonadIO m) => IOError -> m ()+    ignoreStdinClosed e =+      if isResourceVanishedErrorType (ioeGetErrorType e)+        then pure ()+        else liftIO (throwIO e)  -- | Like @sourceProcessWithStreams@ but providing the command to be run as -- a @String@.

@@ -1,6 +1,6 @@ Cabal-version:       >=1.10 Name:                conduit-extra-Version:             1.3.6+Version:             1.3.8 Synopsis:            Batteries included conduit: adapters for common libraries. Description:     The conduit package itself maintains relative small dependencies. The purpose of this package is to collect commonly used utility functions wrapping other library dependencies, without depending on heavier-weight dependencies. The basic idea is that this package should only depend on haskell-platform packages and conduit.@@ -28,12 +28,11 @@                        Data.Conduit.Lazy                        Data.Conduit.Network                        Data.Conduit.Network.UDP+                       Data.Conduit.Network.Unix                        Data.Conduit.Process                        Data.Conduit.Process.Typed                        Data.Conduit.Text                        Data.Conduit.Zlib-  if !os(windows)-      Exposed-modules: Data.Conduit.Network.Unix    if arch(x86_64) || arch(i386)       -- These architectures are able to perform unaligned memory accesses@@ -55,7 +54,7 @@                      , process                      , resourcet                >= 1.1                      , stm-                     , streaming-commons        >= 0.1.16+                     , streaming-commons        >= 0.2.3.0                      , unliftio-core                      , typed-process            >= 0.2.6 

@@ -5,6 +5,7 @@ import Test.Hspec import Test.Hspec.QuickCheck (prop) import Data.Conduit+import qualified Data.Conduit.Combinators as CC import qualified Data.Conduit.List as CL import Data.Conduit.Process import Control.Concurrent.Async (concurrently)@@ -77,6 +78,14 @@                              CL.consume -- stdout                              CL.consume -- stderr                 `shouldReturn` (ExitSuccess, [mystr], [])+    it "gracefully handles closed stdin" $ do+        let blob = L.iterate (+1) 0+            blobHead = L.toStrict $ L.take 10000 blob+        sourceCmdWithStreams "head -c 10000"+                             (CC.sourceLazy blob)+                             (L.toStrict <$> CC.sinkLazy) -- stdout+                             CL.consume -- stderr+                `shouldReturn` (ExitSuccess, blobHead, []) #endif     it "blocking vs non-blocking" $ do         (ClosedStream, ClosedStream, ClosedStream, cph) <- streamingProcess (shell "sleep 1")