diff --git a/spec/outputs/kusto_spec.rb b/spec/outputs/kusto_spec.rb
index 631e086..b276ad8 100755
--- a/spec/outputs/kusto_spec.rb
+++ b/spec/outputs/kusto_spec.rb
@@ -53,7 +53,7 @@
       kusto.multi_receive_encoded(encoded_events)
 
       buffer = kusto.instance_variable_get(:@buffer)
-      expect(buffer.instance_variable_get(:@buffer).size).to eq(2)
+      expect(buffer.instance_variable_get(:@buffer_state)[:pending_items].size).to eq(2)
       RSpec.configuration.reporter.message("Completed test: processes events and adds them to the buffer")
     end