lib/fnordmetric/inbound_stream.rb in fnordmetric-0.7.1 vs lib/fnordmetric/inbound_stream.rb in fnordmetric-0.7.3

@@ -1,43 +1,43 @@
-class FnordMetric::InboundStream < EventMachine::Connection 
+class FnordMetric::InboundStream < EventMachine::Connection
   @@opts = nil
 
   def self.start(opts)
     @@opts = opts
-    EM.start_server(*opts[:inbound_stream], self)    
+    EM.start_server(*(opts[:inbound_stream] << self))
   end
 
   def self.options(opts)
     @@opts = opts
   end
 
-  def receive_data(chunk)     
-    @buffer << chunk         
+  def receive_data(chunk)
+    @buffer << chunk
     next_event
   end
 
   def next_event
     read_next_event
     push_next_event
   end
-  
+
   def read_next_event
     while (event = @buffer.slice!(/^(.*)\n/))
       @events_buffered += 1
       @events << event
-    end 
+    end
   end
 
   def push_next_event
     return true if @events.empty?
     @events_buffered -= 1
     @api.event(@events.pop)
     close_connection?
-    EM.next_tick(&method(:push_next_event))    
+    EM.next_tick(&method(:push_next_event))
   end
 
   def close_connection?
-    @api.disconnect unless @streaming || (@events_buffered!=0) 
+    @api.disconnect unless @streaming || (@events_buffered!=0)
   end
 
   def post_init
     @api = FnordMetric::API.new(@@opts)
     @events_buffered = 0