package.json

@@ -1,6 +1,6 @@
 {
   "name": "purescript-node-stream-pipes",
-  "version": "v2.1.1",
+  "version": "v2.1.0",
   "type": "module",
   "dependencies": {
     "csv-parse": "^5.5.6",

spago.yaml

@@ -1,7 +1,7 @@
 package:
   name: node-stream-pipes
   publish:
-    version: '2.1.1'
+    version: '2.1.0'
     license: 'GPL-3.0-or-later'
     location:
       githubOwner: 'cakekindel'

src/Pipes.Async.purs

@@ -8,7 +8,7 @@ import Control.Monad.Error.Class (class MonadError, class MonadThrow, catchError
 import Control.Monad.Except (ExceptT, runExceptT)
 import Control.Monad.Fork.Class (class MonadBracket, class MonadFork, fork)
 import Control.Monad.Maybe.Trans (MaybeT(..), runMaybeT)
-import Control.Monad.Morph (class MFunctor, hoist)
+import Control.Monad.Morph (hoist)
 import Control.Monad.Rec.Class (class MonadRec, Step(..), tailRecM)
 import Control.Monad.ST.Class (liftST)
 import Control.Monad.ST.Ref (STRef)
@@ -131,18 +131,6 @@ getAsyncIO (Pure _) = pure Nothing
 instance MonadTrans (AsyncPipe a b) where
   lift = M <<< map Pure
 
-instance MFunctor (AsyncPipe a b) where
-  hoist _ (Pure a) = Pure a
-  hoist f (M m) = M $ f $ hoist f <$> m
-  hoist f (AsyncIO ({read, write, awaitWrite, awaitRead} /\ m)) =
-    AsyncIO
-      $ { read: f read
-        , write: f <<< write
-        , awaitWrite: f awaitWrite
-        , awaitRead: f awaitRead
-        }
-        /\ hoist f m
-
 instance Monad m => Functor (AsyncPipe a b m) where
   map f (Pure r) = Pure $ f r
   map f (M m) = M $ map f <$> m