Refactor to reuse mkAsync' for mkAsync
commit67de9947415518edab71c04974c8ff541004948d
authorHarendra Kumar <harendra.kumar@gmail.com>
dateFri 21 Jun 2019, 10:30 (7 years ago)
parent2f4f4cc
src/Streamly/Streams/Async.hs+1−1
@@ -460,7 +460,7 @@ newAsyncVar st m = do
460460-- @since 0.2.0
461461{-# INLINABLE mkAsync #-}
462462mkAsync :: (IsStream t, MonadAsync m) => t m a -> m (t m a)
463−mkAsync m = fmap fromSVar (newAsyncVar defState (toStream m))
463+mkAsync = mkAsync' defState
464464
465465{-# INLINABLE mkAsync' #-}
466466mkAsync' :: (IsStream t, MonadAsync m) => State Stream m a -> t m a -> m (t m a)