diff --git a/Data/Conduit/Async.hs b/Data/Conduit/Async.hs
--- a/Data/Conduit/Async.hs
+++ b/Data/Conduit/Async.hs
@@ -16,6 +16,7 @@
                           ) where
 
 import           Control.Applicative
+import qualified Control.Concurrent.Async as A
 import           Control.Concurrent.Async.Lifted
 import           Control.Concurrent.STM
 import           Control.Concurrent.STM.TBChan
@@ -48,10 +49,10 @@
 buffer size input output = do
     chan <- liftIO $ newTBQueueIO size
     control $ \runInIO ->
-        withAsync (runInIO $ sender chan) $ \input' ->
-        withAsync (runInIO $ recv chan $$ output) $ \output' -> do
-            link2 input' output'
-            wait output'
+        A.withAsync (runInIO $ sender chan) $ \input' ->
+        A.withAsync (runInIO $ recv chan $$ output) $ \output' -> do
+            A.link2 input' output'
+            A.wait output'
   where
     send chan = liftIO . atomically . writeTBQueue chan
 
@@ -100,10 +101,10 @@
         <*> newTVarIO fileMax
         <*> newTVarIO False
     control $ \runInIO ->
-        withAsync (runInIO $ sender context) $ \input' ->
-        withAsync (runInIO $ recv context $$ output) $ \output' -> do
-            link2 input' output'
-            wait output'
+        A.withAsync (runInIO $ sender context) $ \input' ->
+        A.withAsync (runInIO $ recv context $$ output) $ \output' -> do
+            A.link2 input' output'
+            A.wait output'
   where
     sender BufferContext {..} = do
         input $$ awaitForever $ \x -> join $ liftIO $ atomically $ do
diff --git a/stm-conduit.cabal b/stm-conduit.cabal
--- a/stm-conduit.cabal
+++ b/stm-conduit.cabal
@@ -1,5 +1,5 @@
 Name:                stm-conduit
-Version:             2.5.2
+Version:             2.5.3
 Synopsis:            Introduces conduits to channels, and promotes using
                      conduits concurrently.
 Description:         Provides two simple conduit wrappers around STM
