github/semantic
1
1
Fork 0
mirror of https://github.com/github/semantic.git synced 2025-01-03 04:51:57 +03:00
Code Issues Projects Releases Wiki Activity

Encode in renderConcurrently.

Browse Source
This commit is contained in:
Rob Rix 2017-05-26 14:35:05 -04:00
parent 5828dd7969
commit 0b6a805ae5
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/Semantic.hs
View File

@ -35,7 +35,7 @@ diffBlobPairs :: (Monoid output, StringConv output ByteString, HasField fields C
diffBlobPairs decorator renderer blobs = do
diffs <- Async.mapConcurrently go blobs
let diffs' = diffs >>= \ (blobs, diff) -> (,) blobs <$> toList diff
toS <$> renderConcurrently (pure . runRenderer renderer) (diffs' `using` parTraversable (parTuple2 r0 rdeepseq))
renderConcurrently (pure . runRenderer renderer) (diffs' `using` parTraversable (parTuple2 r0 rdeepseq))
where
go blobPair = do
diff <- diffBlobPair decorator blobPair
@ -56,7 +56,7 @@ diffBlobPair decorator blobs = do
-- | Parse a list of SourceBlobs and use the specified renderer to produce ByteString output.
parseBlobs :: (Monoid output, StringConv output ByteString, NFData (Record fields)) => (Source -> Term (Syntax Text) (Record DefaultFields) -> Term (Syntax Text) (Record fields)) -> Renderer (Identity SourceBlob, Term (Syntax Text) (Record fields)) output -> [SourceBlob] -> IO ByteString
parseBlobs decorator renderer blobs =
toS <$> renderConcurrently (fmap (runRenderer renderer) . parse) (filter (not . nonExistentBlob) blobs)
renderConcurrently (fmap (runRenderer renderer) . parse) (filter (not . nonExistentBlob) blobs)
where
parse blob = do
term <- decorator (source blob) <$> runParser (parserForLanguage (blobLanguage blob)) (source blob)
@ -69,7 +69,7 @@ parseBlob decorator SourceBlob{..} = decorator source <$> runParser (parserForLa
-- Internal
renderConcurrently :: (Monoid output, StringConv output ByteString) => (input -> IO output) -> [input] -> IO output
renderConcurrently :: (Monoid output, StringConv output ByteString) => (input -> IO output) -> [input] -> IO ByteString
renderConcurrently f diffs = do
outputs <- Async.mapConcurrently f diffs
pure $ mconcat (outputs `using` parTraversable rseq)
pure $ toS (mconcat (outputs `using` parTraversable rseq))