a4fa2d3 · streamly · git.iko.soy

git.iko.soy/streamly

make some ops INLINE(ABLE)

uncons/zipAsyncWith(M)

commita4fa2d39747a36ec13cda608528bb60d760eabe2 authorHarendra Kumar <harendra.kumar@gmail.com> dateSat 29 Dec 2018, 13:39 (8 years ago) parent25cb5da

2 files changed+3

unifiedsplit

src/Streamly/Prelude.hs+1

@@ -394,6 +394,7 @@ import qualified Streamly.Streams.Serial as Serial

394394-- the head of the stream and @ma@ its tail.

395395--

396396-- @since 0.1.0

397+{-# INLINE uncons #-}

397398uncons :: (IsStream t, Monad m) => SerialT m a -> m (Maybe (a, t m a))

398399uncons m = K.uncons (K.adapt m)

399400

src/Streamly/Streams/Zip.hs+2

@@ -143,6 +143,7 @@ TRAVERSABLE_INSTANCE(ZipSerialM)

143143-- are generated concurrently.

144144--

145145-- @since 0.1.0

146+{-# INLINABLE zipAsyncWith #-}

146147zipAsyncWith :: (IsStream t, MonadAsync m)

147148 => (a -> b -> c) -> t m a -> t m b -> t m c

148149zipAsyncWith f m1 m2 = mkStream $ \st stp sng yld -> do

@@ -154,6 +155,7 @@ zipAsyncWith f m1 m2 = mkStream $ \st stp sng yld -> do

154155-- are generated concurrently.

155156--

156157-- @since 0.4.0

158+{-# INLINABLE zipAsyncWithM #-}

157159zipAsyncWithM :: (IsStream t, MonadAsync m)

158160 => (a -> b -> m c) -> t m a -> t m b -> t m c

159161zipAsyncWithM f m1 m2 = mkStream $ \st stp sng yld -> do