lib/pupil/stream/base.rb in pupil-0.1.4 vs lib/pupil/stream/base.rb in pupil-0.1.5

@@ -1,9 +1,8 @@
 class Pupil
   class Stream
     attr_reader :screen_name
-    class StreamError < StandardError ; end
     STREAM_APIS = {
       :userstream => "https://userstream.twitter.com/2/user.json",
       :search => "https://stream.twitter.com/1/statuses/filter.json%s"
     }
 
@@ -35,35 +34,31 @@
       https.use_ssl = true
       https.verify_mode = OpenSSL::SSL::VERIFY_NONE
       https.verify_depth = 5
 
       while true do
-        begin
-          https.start do |https|
-            request = Net::HTTP::Get.new(uri.request_uri)
-            request["User-Agent"] = "Ruby/#{RUBY_VERSION} Pupil::Stream"
-            request.oauth!(https, @consumer, @access_token)
-            buf = ""
-            https.request(request) do |response|
-              response.read_body do |chunk|
-                buf << chunk
-                while (line = buf[/.+?(\r\n)+/m]) != nil
-                  begin
-                    buf.sub!(line,"")
-                    line.strip!
-                    status = JSON.parse(line)
-                  rescue
-                    break
-                  end
-
-                  event = self.guess_event status
-                  block.call event
+        https.start do |https|
+          request = Net::HTTP::Get.new(uri.request_uri)
+          request["User-Agent"] = "Ruby/#{RUBY_VERSION} Pupil::Stream"
+          request.oauth!(https, @consumer, @access_token)
+          buf = ""
+          https.request(request) do |response|
+            response.read_body do |chunk|
+              buf << chunk
+              while (line = buf[/.+?(\r\n)+/m]) != nil
+                begin
+                  buf.sub!(line,"")
+                  line.strip!
+                  status = JSON.parse(line)
+                rescue
+                  break
                 end
+
+                event = self.guess_event status
+                block.call event
               end
             end
           end
-        rescue => vars
-          raise StreamError, "StreamError: #{vars}"
         end
       end
     end
 
     def guess_event status