diff --git a/server/src/main/java/org/elasticsearch/index/engine/Engine.java b/server/src/main/java/org/elasticsearch/index/engine/Engine.java
index 5a1c49b54b7ac..eaa24ab6c0e89 100644
--- a/server/src/main/java/org/elasticsearch/index/engine/Engine.java
+++ b/server/src/main/java/org/elasticsearch/index/engine/Engine.java
@@ -998,6 +998,11 @@ public final SearcherSupplier acquireSearcherSupplier(Function<Searcher, Searche
     // Called before a {@link Searcher} is created, to allow subclasses to perform any stats or logging operations.
     protected void onSearcherCreation(String source, SearcherScope scope) {}
 
+    // Allows subclasses to wrap the DirectoryReader before it is used to create Searchers
+    protected DirectoryReader wrapDirectoryReader(DirectoryReader reader) throws IOException {
+        return reader;
+    }
+
     /**
      * Acquires a point-in-time reader that can be used to create {@link Engine.Searcher}s on demand.
      */
@@ -1012,6 +1017,7 @@ public SearcherSupplier acquireSearcherSupplier(Function<Searcher, Searcher> wra
         try {
             ReferenceManager<ElasticsearchDirectoryReader> referenceManager = getReferenceManager(scope);
             ElasticsearchDirectoryReader acquire = referenceManager.acquire();
+            DirectoryReader wrappedDirectoryReader = wrapDirectoryReader(acquire);
             SearcherSupplier reader = new SearcherSupplier(wrapper) {
                 @Override
                 public Searcher acquireSearcherInternal(String source) {
@@ -1019,7 +1025,7 @@ public Searcher acquireSearcherInternal(String source) {
                     onSearcherCreation(source, scope);
                     return new Searcher(
                         source,
-                        acquire,
+                        wrappedDirectoryReader,
                         engineConfig.getSimilarity(),
                         engineConfig.getQueryCache(),
                         engineConfig.getQueryCachingPolicy(),