This commit is contained in:
voidlizard 2025-01-15 10:17:49 +03:00
parent e725861292
commit a7aaa83a8c
1 changed files with 4 additions and 3 deletions

View File

@ -10,6 +10,7 @@ import HBS2.Data.Log.Structured
import Data.ByteString qualified as BS import Data.ByteString qualified as BS
import Data.ByteString.Lazy ( ByteString ) import Data.ByteString.Lazy ( ByteString )
import Data.ByteString.Lazy qualified as LBS import Data.ByteString.Lazy qualified as LBS
import Data.ByteString.Lazy.Char8 qualified as LBS8
import Data.List qualified as L import Data.List qualified as L
import Network.ByteOrder qualified as N import Network.ByteOrder qualified as N
import System.IO.Temp as Temp import System.IO.Temp as Temp
@ -381,10 +382,10 @@ updateReflogIndex = do
guard (LBS.length what > 0) guard (LBS.length what > 0)
notice $ "unpacked!" <+> pretty h <+> pretty (LBS.length what)
pieces <- S.toList_ $ do pieces <- S.toList_ $ do
void $ runConsumeLBS what $ readLogFileLBS () $ \o _ _ -> do void $ runConsumeLBS what $ readLogFileLBS () $ \o _ lbs -> do
let (t, _) = LBS.splitAt 1 lbs
notice $ pretty (LBS8.unpack t) <+> pretty o
lift $ S.yield o lift $ S.yield o
lift $ S.yield (h, pieces) lift $ S.yield (h, pieces)