diff --git a/library/Potoki/Core/Transform.hs b/library/Potoki/Core/Transform.hs
--- a/library/Potoki/Core/Transform.hs
+++ b/library/Potoki/Core/Transform.hs
@@ -33,6 +33,7 @@
   -- * Concurrency
   N.bufferize,
   N.concurrently,
+  N.unsafeConcurrently,
   N.async,
   -- * File IO
   deleteFile,
diff --git a/library/Potoki/Core/Transform/Attoparsec.hs b/library/Potoki/Core/Transform/Attoparsec.hs
--- a/library/Potoki/Core/Transform/Attoparsec.hs
+++ b/library/Potoki/Core/Transform/Attoparsec.hs
@@ -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))
diff --git a/library/Potoki/Core/Transform/Concurrency.hs b/library/Potoki/Core/Transform/Concurrency.hs
--- a/library/Potoki/Core/Transform/Concurrency.hs
+++ b/library/Potoki/Core/Transform/Concurrency.hs
@@ -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
diff --git a/potoki-core.cabal b/potoki-core.cabal
--- a/potoki-core.cabal
+++ b/potoki-core.cabal
@@ -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