@@ -51,7 +51,7 @@ import Test.Inspection (inspect, hasNoTypeClassesExcept)
5151
5252-- | Pull a stream from an SVar.
5353{-# NOINLINE fromStreamVar #-}
54−fromStreamVar :: forall m a . MonadAsync m => SVar Stream m a -> Stream m a
54+fromStreamVar :: MonadAsync m => SVar Stream m a -> Stream m a
5555fromStreamVar sv = MkStream $ \st yld sng stp -> do
5656 list <- readOutputQ sv
5757 -- Reversing the output is important to guarantee that we process the
@@ -60,7 +60,7 @@ fromStreamVar sv = MkStream $ \st yld sng stp -> do
6060 foldStream st yld sng stp $ processEvents $ reverse list
6161
6262 where
63− allDone :: m r -> m r
63+
6464 allDone stp = do
6565 when (svarInspectMode sv) $ do
6666 t <- liftIO $ getTime Monotonic
@@ -69,7 +69,6 @@ fromStreamVar sv = MkStream $ \st yld sng stp -> do
6969 stp
7070
7171 {-# INLINE processEvents #-}
72− processEvents :: [ChildEvent a] -> Stream m a
7372 processEvents [] = MkStream $ \st yld sng stp -> do
7473 done <- postProcess sv
7574 if done
@@ -93,7 +92,6 @@ fromStreamVar sv = MkStream $ \st yld sng stp -> do
9392 Just ThreadAbort ->
9493 foldStream st yld sng stp rest
9594 Nothing -> liftIO (cleanupSVar sv) >> throwM ex
96−
9795 shouldStop tid =
9896 case svarStopStyle sv of
9997 StopNone -> return False