diff --git a/conduit-concurrent-map.cabal b/conduit-concurrent-map.cabal
--- a/conduit-concurrent-map.cabal
+++ b/conduit-concurrent-map.cabal
@@ -1,5 +1,5 @@
 name:          conduit-concurrent-map
-version:       0.1.0
+version:       0.1.1
 license:       MIT
 copyright:     2017 Niklas Hambüchen <mail@nh2.me>
 author:        Niklas Hambüchen <mail@nh2.me>
diff --git a/src/Data/Conduit/ConcurrentMap.hs b/src/Data/Conduit/ConcurrentMap.hs
--- a/src/Data/Conduit/ConcurrentMap.hs
+++ b/src/Data/Conduit/ConcurrentMap.hs
@@ -109,7 +109,7 @@
 --
 -- > puts :: (MonadIO m) => String -> m () -- for non-interleaved output
 -- > puts s = liftIO $ BS8.putStrLn (BS8.pack s)
--- > runConduitRes (CL.sourceList [1..6] .| conduitconcurrentMapM_ 4 (\i -> liftIO $ puts (show i ++ " before") >> threadDelay (i * 1000000) >> puts (show i ++ " after") >> return (i*2)) .| CL.consume )
+-- > runConduitRes (CL.sourceList [1..6] .| concurrentMapM_ 4 (\i -> liftIO $ puts (show i ++ " before") >> threadDelay (i * 1000000) >> puts (show i ++ " after") >> return (i*2)) .| CL.consume )
 concurrentMapM_ :: (MonadUnliftIO m, MonadResource m) => Int -> Int -> (a -> m b) -> ConduitT a b m ()
 concurrentMapM_ numThreads workerOutputBufferSize f = do
   when (workerOutputBufferSize < 1) $ do