spec/inputs/s3_spec.rb in logstash-input-s3-3.1.1 vs spec/inputs/s3_spec.rb in logstash-input-s3-3.1.2

@@ -206,13 +206,15 @@
       end
     end
   end
 
   shared_examples "generated events"  do
+    let(:events_to_process) { 2 }
+
     it 'should process events' do
       events = fetch_events(config)
-      expect(events.size).to eq(2)
+      expect(events.size).to eq(events_to_process)
     end
 
     it "deletes the temporary file" do
       events = fetch_events(config)
       expect(Dir.glob(File.join(temporary_directory, "*")).size).to eq(0)
@@ -247,9 +249,18 @@
           "codec" => "json",
         }
       }
 
       include_examples "generated events"
+    end
+
+    context "multiple compressed streams" do
+      let(:log) { double(:key => 'log.gz', :last_modified => Time.now - 2 * day) }
+      let(:log_file) { File.join(File.dirname(__FILE__), '..', 'fixtures', 'multiple_compressed_streams.gz') }
+
+      include_examples "generated events" do
+        let(:events_to_process) { 16 }
+      end
     end
 
     context 'compressed' do
       let(:log) { double(:key => 'log.gz', :last_modified => Time.now - 2 * day) }
       let(:log_file) { File.join(File.dirname(__FILE__), '..', 'fixtures', 'compressed.log.gz') }