lib/fnordmetric/inbound_stream.rb in fnordmetric-0.6.2 vs lib/fnordmetric/inbound_stream.rb in fnordmetric-0.6.3

@@ -4,10 +4,14 @@
   def self.start(opts)
     @@opts = opts
     EM.start_server(*opts[:inbound_stream], self)    
   end
 
-  def receive_data(chunk)        
+  def self.options(opts)
+    @@opts = opts
+  end
+
+  def receive_data(chunk)     
     @buffer << chunk         
     EM.defer{ next_event }
   end
 
   def next_event