on master help sign in
Refactor unstreamShared to unStreamShared.
commit7c2b9b7c8a55b2c33bfc49ebbad24ed01c926db8 authorPranay Sashank <pranaysashank@gmail.com> dateFri 30 Nov 2018, 01:20 (8 years ago) parentffab417
2 files changed+7−7
src/Streamly/Streams/Ahead.hs+2−2 src/Streamly/Streams/StreamK.hs+5−5
src/Streamly/Streams/Ahead.hs+2−2
@@ -48,7 +48,7 @@ import Streamly.Streams.SVar (fromSVar)
4848import Streamly.Streams.Serial (map)
4949import Streamly.SVar
5050import Streamly.Streams.StreamK
51− (IsStream(..), Stream(..), unstreamShared, unStreamIsolated,
51+ (IsStream(..), Stream(..), unStreamShared, unStreamIsolated,
5252 runStreamSVar)
5353import qualified Streamly.Streams.StreamK as K
5454
@@ -683,7 +683,7 @@ aheadbind m f = go m
683683 where
684684 go (Stream g) =
685685 Stream $ \st stp sng yld ->
686− let runShared x = unstreamShared x st stp sng yld
686+ let runShared x = unStreamShared x st stp sng yld
687687 runIsolated x = unStreamIsolated x st stp sng yld
688688
689689 single a = runIsolated $ f a
src/Streamly/Streams/StreamK.hs+5−5
@@ -35,7 +35,7 @@ module Streamly.Streams.StreamK
3535 , Stream (..)
3636 , unStreamIsolated
3737 , isolateStream
38− , unstreamShared
38+ , unStreamShared
3939 , runStreamSVar
4040
4141 -- * Construction
@@ -224,15 +224,15 @@ isolateStream x = Stream $ \st stp sng yld ->
224224 unStreamIsolated x st stp sng yld
225225
226226-- | Like unstream, but passes a shared SVar across continuations.
227−{-# INLINE unstreamShared #-}
228−unstreamShared ::
227+{-# INLINE unStreamShared #-}
228+unStreamShared ::
229229 Stream m a
230230 -> State Stream m a -- state
231231 -> m r -- stop
232232 -> (a -> m r) -- singleton
233233 -> (a -> Stream m a -> m r) -- yield
234234 -> m r
235−unstreamShared = unStream
235+unStreamShared = unStream
236236
237237-- Run the stream using a run function associated with the SVar that runs the
238238-- streams with a captured snapshot of the monadic state.
@@ -1208,7 +1208,7 @@ bindWith par m f = go m
12081208 where
12091209 go (Stream g) =
12101210 Stream $ \st stp sng yld ->
1211− let runShared x = unstreamShared x st stp sng yld
1211+ let runShared x = unStreamShared x st stp sng yld
12121212 runIsolated x = unStreamIsolated x st stp sng yld
12131213
12141214 single a = runIsolated $ f a