diff --git a/spec/lib/waterdrop/instrumentation/callbacks/delivery_spec.rb b/spec/lib/waterdrop/instrumentation/callbacks/delivery_spec.rb index 2d77263e..1981d255 100644 --- a/spec/lib/waterdrop/instrumentation/callbacks/delivery_spec.rb +++ b/spec/lib/waterdrop/instrumentation/callbacks/delivery_spec.rb @@ -56,7 +56,7 @@ context 'when there is a message that was not successfully delivered async' do let(:changed) { [] } - let(:event) { changed.first } + let(:event) { changed.last } before do producer.monitor.subscribe('error.occurred') do |event|