1a46cd5 · streamly · git.iko.soy

git.iko.soy/streamly

on master help sign in

Add newlines in the Channel dump function

1a46cd5Harendra Kumar4 years ago

src/Streamly/Internal/Data/Stream/Async/Channel/Type.hs+2−1

@@ -18,6 +18,7 @@ where

18import Control.Concurrent (ThreadId)

19import Control.Concurrent.MVar (MVar)

20import Data.IORef (IORef)

21+import Data.List (intersperse)

21import Data.Set (Set)

22import Data.Set (Set)

23import Streamly.Internal.Control.Concurrent (RunInIO)

24import Streamly.Internal.Control.Concurrent (RunInIO)

@@ -138,7 +139,7 @@ stop sv winfo =

138{-# NOINLINE dumpSVar #-}

139{-# NOINLINE dumpSVar #-}

139dumpSVar :: Channel m a -> IO String

140dumpSVar :: Channel m a -> IO String

140dumpSVar sv = do

141dumpSVar sv = do

141− xs <- sequence

142+ xs <- sequence $ intersperse (return "\n")

142 [ return (dumpCreator (svarCreator sv))

143 [ return (dumpCreator (svarCreator sv))

143 , return "---------CURRENT STATE-----------"

144 , return "---------CURRENT STATE-----------"

144 , dumpOutputQ (outputQueue sv)

145 , dumpOutputQ (outputQueue sv)