diff --git a/extensions/elasticsearch/ActiveFixture.php b/extensions/elasticsearch/ActiveFixture.php
index 4edf59e..6731dc0 100644
--- a/extensions/elasticsearch/ActiveFixture.php
+++ b/extensions/elasticsearch/ActiveFixture.php
@@ -111,6 +111,8 @@ class ActiveFixture extends BaseActiveFixture
             }
             $this->data[$alias] = $row;
         }
+        // ensure all data is flushed and immediately available in the test
+        $this->db->createCommand()->flushIndex($this->index);
     }
 
     /**