@@ -406,10 +406,10 @@ func TestStorageDiff_MissingAncestorHeaderFallsBackToUncompressed(t *testing.T)
406406 Return (int64 (payloadSize ), nil ).Once ()
407407 rawSeekable .EXPECT ().
408408 OpenRangeReader (mock .Anything , mock .Anything , mock .Anything , mock .Anything ).
409- RunAndReturn (func (_ context.Context , off , length int64 , _ * storage.FrameTable ) (io. ReadCloser , error ) {
409+ RunAndReturn (func (_ context.Context , off , length int64 , _ * storage.FrameTable ) (storage. RangeReader , error ) {
410410 end := min (off + length , int64 (len (payload )))
411411
412- return io .NopCloser (bytes .NewReader (payload [off :end ])), nil
412+ return storage . NewRangeReader ( io .NopCloser (bytes .NewReader (payload [off :end ]) )), nil
413413 })
414414 provider .EXPECT ().
415415 OpenSeekable (mock .Anything , aPaths .DataFile (storage .MemfileName , storage .CompressionNone ), mock .Anything ).
@@ -460,10 +460,10 @@ func TestStorageDiff_BackfillMarkerLatchesUncompressedAtConstruction(t *testing.
460460 Return (int64 (payloadSize ), nil ).Once ()
461461 rawSeekable .EXPECT ().
462462 OpenRangeReader (mock .Anything , mock .Anything , mock .Anything , mock .Anything ).
463- RunAndReturn (func (_ context.Context , off , length int64 , _ * storage.FrameTable ) (io. ReadCloser , error ) {
463+ RunAndReturn (func (_ context.Context , off , length int64 , _ * storage.FrameTable ) (storage. RangeReader , error ) {
464464 end := min (off + length , int64 (len (payload )))
465465
466- return io .NopCloser (bytes .NewReader (payload [off :end ])), nil
466+ return storage . NewRangeReader ( io .NopCloser (bytes .NewReader (payload [off :end ]) )), nil
467467 })
468468 provider .EXPECT ().
469469 OpenSeekable (mock .Anything , aPaths .DataFile (storage .MemfileName , storage .CompressionNone ), mock .Anything ).
0 commit comments