lib/fnordmetric/inbound_stream.rb in fnordmetric-0.6.4 vs lib/fnordmetric/inbound_stream.rb in fnordmetric-0.6.5

@@ -10,11 +10,11 @@
     @@opts = opts
   end
 
   def receive_data(chunk)     
     @buffer << chunk         
-    EM.defer{ next_event }
+    next_event
   end
 
   def next_event
     read_next_event
     push_next_event
@@ -42,10 +42,10 @@
   def post_init
     @api = FnordMetric::API.new(@@opts)
     @events_buffered = 0
     @streaming = true
     @buffer = ""
-    @events = []          
+    @events = []
   end
 
   def unbind
     @streaming = false
     close_connection?