diff --git a/changelogs/unreleased/10225-Lyndon-Li b/changelogs/unreleased/10225-Lyndon-Li
new file mode 100644
index 000000000..435da13d1
--- /dev/null
+++ b/changelogs/unreleased/10225-Lyndon-Li
@@ -0,0 +1 @@
+Add prefetch mechanism to object reader so as to improve the restore throughput of block data mover
\ No newline at end of file
diff --git a/pkg/repository/udmrepo/kopialib/lib_repo.go b/pkg/repository/udmrepo/kopialib/lib_repo.go
index 0efde34a7..e60128358 100644
--- a/pkg/repository/udmrepo/kopialib/lib_repo.go
+++ b/pkg/repository/udmrepo/kopialib/lib_repo.go
@@ -382,7 +382,6 @@ func (kr *kopiaRepository) OpenObject(ctx context.Context, id udmrepo.ID, opt ud
 
 			prefetch.cond = sync.NewCond(&prefetch.mu)
 		}
-
 	}
 
 	rd := &kopiaObjectReader{
diff --git a/pkg/repository/udmrepo/kopialib/lib_repo_test.go b/pkg/repository/udmrepo/kopialib/lib_repo_test.go
index 6bd64009c..b4d487c43 100644
--- a/pkg/repository/udmrepo/kopialib/lib_repo_test.go
+++ b/pkg/repository/udmrepo/kopialib/lib_repo_test.go
@@ -908,7 +908,7 @@ func TestReaderClose(t *testing.T) {
 			err := kr.Close()
 
 			if tc.withPrefetch {
-				assert.ErrorIs(t, kr.prefetch.ctx.Err(), context.Canceled)
+				require.ErrorIs(t, kr.prefetch.ctx.Err(), context.Canceled)
 			}
 
 			if tc.expectedErr == "" {
diff --git a/pkg/uploader/block/uploader_test.go b/pkg/uploader/block/uploader_test.go
index 3b8930476..1b1eddbce 100644
--- a/pkg/uploader/block/uploader_test.go
+++ b/pkg/uploader/block/uploader_test.go
@@ -663,7 +663,7 @@ func TestBlockUploaderRestore(t *testing.T) {
 		objReader.On("Read", mock.Anything).Return(0, io.EOF)
 		objReader.On("Close").Return(nil)
 
-		repoWriter.On("OpenObject", mock.Anything, udmrepo.ID("data-id")).Return(objReader, nil)
+		repoWriter.On("OpenObject", mock.Anything, udmrepo.ID("data-id"), mock.Anything).Return(objReader, nil)
 
 		snap := udmrepo.Snapshot{
 			Description: "test snapshot",
diff --git a/pkg/uploader/kopia/shim_test.go b/pkg/uploader/kopia/shim_test.go
index 7933ec6b8..3c7941405 100644
--- a/pkg/uploader/kopia/shim_test.go
+++ b/pkg/uploader/kopia/shim_test.go
@@ -81,7 +81,7 @@ func TestOpenObject(t *testing.T) {
 			name: "Success",
 			backupRepo: func() *mocks.BackupRepo {
 				backupRepo := &mocks.BackupRepo{}
-				backupRepo.On("OpenObject", mock.Anything, mock.Anything).Return(&shimObjectReader{}, nil)
+				backupRepo.On("OpenObject", mock.Anything, mock.Anything, mock.Anything).Return(&shimObjectReader{}, nil)
 				return backupRepo
 			}(),
 		},
@@ -89,7 +89,7 @@ func TestOpenObject(t *testing.T) {
 			name: "Open object error",
 			backupRepo: func() *mocks.BackupRepo {
 				backupRepo := &mocks.BackupRepo{}
-				backupRepo.On("OpenObject", mock.Anything, mock.Anything).Return(&shimObjectReader{}, errors.New("Error open object"))
+				backupRepo.On("OpenObject", mock.Anything, mock.Anything, mock.Anything).Return(&shimObjectReader{}, errors.New("Error open object"))
 				return backupRepo
 			}(),
 			isOpenObjectError: true,
@@ -98,7 +98,7 @@ func TestOpenObject(t *testing.T) {
 			name: "Get nil reader",
 			backupRepo: func() *mocks.BackupRepo {
 				backupRepo := &mocks.BackupRepo{}
-				backupRepo.On("OpenObject", mock.Anything, mock.Anything).Return(nil, nil)
+				backupRepo.On("OpenObject", mock.Anything, mock.Anything, mock.Anything).Return(nil, nil)
 				return backupRepo
 			}(),
 			isReaderNil: true,