stream.rb.patch

diff --git lib/atig/stream.rb lib/atig/stream.rb
index 069c0df..5f93731 100644
--- lib/atig/stream.rb
+++ lib/atig/stream.rb
@@ -46,12 +46,12 @@ module Atig
             next if chunk.chomp.empty?
             buffer << chunk.to_s

-            if buffer =~ /\A(.*)\n/ then
-              text = $1
-              unless text.strip.empty?
-                f.call TwitterStruct.make(JSON.parse(text))
+            buffer.split("\r\n").each do |line|
+              if line =~ /\A\{.*\}\Z/ then
+                f.call TwitterStruct.make(JSON.parse(line))
+              else
+                buffer = line
               end
-              buffer = ''
             end
           end
         rescue => e