Skip to content
Draft
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
23 changes: 22 additions & 1 deletion benchmark/Streamly/Benchmark/FileSystem/Handle/Read.hs
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,7 @@ module Handle.Read
(allBenchmarks)
where

import Control.Monad (void)
import Data.Char (ord)
import Data.Functor.Identity (runIdentity)
import Data.Word (Word8)
Expand All @@ -32,11 +33,12 @@ import GHC.Magic (noinline)
#else
#define noinline
#endif
import System.IO (Handle)
import System.IO (Handle, hClose, openFile, IOMode(..))
import Prelude hiding (last, length)

import qualified Streamly.Data.Fold as FL
import qualified Streamly.Unicode.Stream as SS
import qualified Streamly.Internal.Data.Json.Stream as SJ
import qualified Streamly.FileSystem.Handle as FH
-- import qualified Streamly.Internal.Data.Fold as IFL
import qualified Streamly.Internal.Data.Parser as PR
Expand Down Expand Up @@ -246,6 +248,24 @@ readDecodeUtf8 inh =
$ SS.decodeUtf8
$ S.unfold FH.read inh

readJsonDrain :: Handle -> IO ()
readJsonDrain inh =
void
$ IP.parse SJ.parseJson
$ S.unfold FH.read inh

o_n_space_parse_json :: [Benchmark]
o_n_space_parse_json =
[ bgroup
"parse/json"
[ bench "parseJson" $
nfIO $ do
inh <- openFile "twitter.json" ReadMode
readJsonDrain inh
hClose inh
]
]

#ifdef INSPECTION
inspect $ hasNoTypeClasses 'readDecodeUtf8
-- inspect $ 'readDecodeUtf8Lax `hasNoType` ''Step
Expand Down Expand Up @@ -531,4 +551,5 @@ allBenchmarks env = Prelude.concat
, o_1_space_reduce_read_grouped env
, o_1_space_reduce_read_split env
, o_1_space_reduce_toChunks_split env
, o_n_space_parse_json
]
Loading