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 >>>
-  concurrently concurrency (arr (mapLeft fromString . K.parseOnly parser))
+  concurrentlyUnsafe 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 >>>
-  concurrently concurrency (arr (mapLeft fromString . K.parseOnly parser))
+  concurrentlyUnsafe 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
@@ -1,9 +1,4 @@
 module Potoki.Core.Transform.Concurrency
-(
-  bufferize,
-  concurrently,
-  async,
-)
 where
 
 import Potoki.Core.Prelude hiding (take, takeWhile, filter)
diff --git a/potoki-core.cabal b/potoki-core.cabal
--- a/potoki-core.cabal
+++ b/potoki-core.cabal
@@ -1,7 +1,7 @@
 name:
   potoki-core
 version:
-  2.2.5.2
+  2.2.5.3
 synopsis:
   Low-level components of "potoki"
 description: