git.iko.soy/streamly
on master help sign in
Refactor to reuse mkAsync' for mkAsync
67de994Harendra Kumar
src/Streamly/Streams/Async.hs+1−1
compare with master
unifiedsplit
@@ -460,7 +460,7 @@ newAsyncVar st m = do
460-- @since 0.2.0
460-- @since 0.2.0
461{-# INLINABLE mkAsync #-}
461{-# INLINABLE mkAsync #-}
462mkAsync :: (IsStream t, MonadAsync m) => t m a -> m (t m a)
462mkAsync :: (IsStream t, MonadAsync m) => t m a -> m (t m a)
463−mkAsync m = fmap fromSVar (newAsyncVar defState (toStream m))
463+mkAsync = mkAsync' defState
464
464
465{-# INLINABLE mkAsync' #-}
465{-# INLINABLE mkAsync' #-}
466mkAsync' :: (IsStream t, MonadAsync m) => State Stream m a -> t m a -> m (t m a)
466mkAsync' :: (IsStream t, MonadAsync m) => State Stream m a -> t m a -> m (t m a)