src/git_kv.ml

@@ -278,7 +278,8 @@ let map buf ~pos len =
 let blit_from_string src src_off dst dst_off len =
   Bigstringaf.blit_from_string src ~src_off dst ~dst_off ~len
 
-let read ke stream =
+let read stream =
+  let ke = Ke.Rke.create ~capacity:0x1000 Bigarray.char in
   let rec go filled input =
     match Ke.Rke.N.peek ke with
     | [] -> begin
@@ -301,10 +302,9 @@ let read ke stream =
 let analyze store stream =
   let tmp = Cstruct.create 0x1000 in
   let buf = Buffer.create 0x1000 in
-  let ke = Ke.Rke.create ~capacity:0x1000 Bigarray.char in
   let read_cstruct tmp =
     let open Lwt.Infix in
-    read ke stream tmp >>= fun len ->
+    read stream tmp >>= fun len ->
     Buffer.add_string buf (Cstruct.to_string ~off:0 ~len tmp);
     Lwt.return len in
   let allocate bits = De.make_window ~bits in