lib/fluent/plugin/in_cloudwatch_logs.rb in fluent-plugin-cloudwatch-logs-0.4.1 vs lib/fluent/plugin/in_cloudwatch_logs.rb in fluent-plugin-cloudwatch-logs-0.4.2.pre

@@ -100,12 +100,12 @@
         if Time.now > @next_fetch_time
           @next_fetch_time += @fetch_interval
 
           if @use_log_stream_name_prefix
             log_streams = describe_log_streams
-            log_streams.each do |log_stram|
-              log_stream_name = log_stram.log_stream_name
+            log_streams.each do |log_stream|
+              log_stream_name = log_stream.log_stream_name
               events = get_events(log_stream_name)
               events.each do |event|
                 emit(log_stream_name, event)
               end
             end
@@ -149,10 +149,10 @@
       }
       request[:next_token] = next_token if next_token
       request[:log_stream_name_prefix] = @log_stream_name
       response = @logs.describe_log_streams(request)
       if log_streams
-        log_streams << response.log_streams
+        log_streams.concat(response.log_streams)
       else
         log_streams = response.log_streams
       end
       if response.next_token
         log_streams = describe_log_streams(log_streams, response.next_token)