@@ -1069,6 +1069,7 @@ newEmptySVar style = do
10691069 AheadVar -> getAheadSVar style
10701070
10711071-- | Create a new SVar and enqueue one stream computation on it.
1072+{-# INLINABLE newStreamVar1 #-}
10721073newStreamVar1 :: MonadAsync m => SVarStyle -> Stream m a -> m (SVar m a)
10731074newStreamVar1 style m = do
10741075 sv <- newEmptySVar style
@@ -1083,6 +1084,7 @@ newStreamVar1 style m = do
10831084 return sv
10841085
10851086-- | Create a new SVar and enqueue one stream computation on it.
1087+{-# INLINABLE newStreamVarAhead #-}
10861088newStreamVarAhead :: MonadAsync m => Stream m a -> m (SVar m a)
10871089newStreamVarAhead m = do
10881090 sv <- newEmptySVar AheadVar