potoki-core 2.2.6.1 → 2.2.7

raw patch · 4 files changed

+8/−7 lines, 4 filesPVP ok

version bump matches the API change (PVP)

API changes (from Hackage documentation)

Files

• library/Potoki/Core/Transform.hs +1/−0
• library/Potoki/Core/Transform/Attoparsec.hs +2/−2
• library/Potoki/Core/Transform/Concurrency.hs +4/−4
• potoki-core.cabal +1/−1

@@ -33,6 +33,7 @@   -- * Concurrency   N.bufferize,   N.concurrently,+  N.unsafeConcurrently,   N.async,   -- * File IO   deleteFile,

@@ -94,7 +94,7 @@ parseLineBytesConcurrently :: Int -> K.Parser a -> Transform ByteString (Either Text a) parseLineBytesConcurrently concurrency parser =   extractLines >>> bufferize concurrency >>>-  concurrentlyUnsafe concurrency (arr (mapLeft fromString . K.parseOnly parser))+  unsafeConcurrently concurrency (arr (mapLeft fromString . K.parseOnly parser))  {-| Lift an Attoparsec ByteString parser to a transform,@@ -104,4 +104,4 @@ parseNonEmptyLineBytesConcurrently :: Int -> K.Parser a -> Transform ByteString (Either Text a) parseNonEmptyLineBytesConcurrently concurrency parser =   extractLinesWithoutTrail >>> filter (not . ByteString.null) >>> bufferize (concurrency * 2) >>>-  concurrentlyUnsafe concurrency (arr (mapLeft fromString . K.parseOnly parser))+  unsafeConcurrently concurrency (arr (mapLeft fromString . K.parseOnly parser))

@@ -67,11 +67,11 @@     then transform     else       sync >>>-      concurrentlyUnsafe workersAmount transform+      unsafeConcurrently workersAmount transform -{-# INLINE concurrentlyUnsafe #-}-concurrentlyUnsafe :: Int -> Transform input output -> Transform input output-concurrentlyUnsafe workersAmount (Transform syncTransformIO) = +{-# INLINE unsafeConcurrently #-}+unsafeConcurrently :: Int -> Transform input output -> Transform input output+unsafeConcurrently workersAmount (Transform syncTransformIO) =    Transform $ \ fetchIO -> liftIO $ do     chan <- newTBQueueIO (workersAmount * 2)     workersCounter <- newTVarIO workersAmount

@@ -1,5 +1,5 @@ name: potoki-core-version: 2.2.6.1+version: 2.2.7 synopsis: Low-level components of "potoki" description:   Provides everything required for building custom instances of