wip

2025-05-13 10:46:09 +03:00 · 2025-05-13 10:46:09 +03:00 · 9722fa7c01
parent aa3d32387d
commit 9722fa7c01
2 changed files with 3 additions and 1 deletions
--- a/hbs2-storage-ncq/lib/HBS2/Storage/NCQ.hs
+++ b/hbs2-storage-ncq/lib/HBS2/Storage/NCQ.hs
@ -310,7 +310,7 @@ ncqStorageRun ncq@NCQStorage{..} = flip runContT pure do
  indexer    <- makeIndexer indexQ
  writer     <- makeWriter indexQ

-  mapM_ waitCatch [writer,refsWriter]
+  mapM_ waitCatch [writer,indexer,refsWriter]
  -- mapM_ waitCatch [writer,indexer,refsWriter] -- ,indexer,refsWriter]
  mapM_ cancel  [reader]

--- a/hbs2-tests/test/TCQ.hs
+++ b/hbs2-tests/test/TCQ.hs
@ -133,6 +133,8 @@ main = do

        internalEntries

+        entry $ bindMatch "#!" $ nil_ $ const none
+
        entry $ bindMatch "--run" $ \case
          [ StringLike what ] -> liftIO do
            liftIO (readFile what)