a4fa2d3 · streamly · git.iko.soy

git.iko.soy/streamly

on master help sign in

make some ops INLINE(ABLE)

a4fa2d3Harendra Kumar8 years ago

src/Streamly/Prelude.hs+1

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

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

395--

396-- @since 0.1.0

397+{-# INLINE uncons #-}

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

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

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

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

399

400

src/Streamly/Streams/Zip.hs+2

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

143-- are generated concurrently.

144--

145-- @since 0.1.0

146+{-# INLINABLE zipAsyncWith #-}

146zipAsyncWith :: (IsStream t, MonadAsync m)

147zipAsyncWith :: (IsStream t, MonadAsync m)

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

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

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

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

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

154-- are generated concurrently.

155-- are generated concurrently.

155--

156--

156-- @since 0.4.0

157-- @since 0.4.0

158+{-# INLINABLE zipAsyncWithM #-}

157zipAsyncWithM :: (IsStream t, MonadAsync m)

159zipAsyncWithM :: (IsStream t, MonadAsync m)

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

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

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

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