feed.rb in fluq-0.8.0

- old
+ new
@@ -1,6 +1,41 @@
-module FluQ::Feed
-end
+class FluQ::Feed < Celluloid::SupervisionGroup
 
-%w'base msgpack json tsv'.each do |name|
-  require "fluq/feed/#{name}"
-end
\ No newline at end of file
+  # @attr_reader [String] name
+  attr_reader :name
+
+  # @attr_reader [Array] handlers
+  attr_reader :handlers
+
+  # Constructor
+  # @param [String] name feed name
+  def initialize(name, &block)
+    @name     = name.to_s
+    @handlers = []
+    super(&block)
+  end
+
+  # @return [Array<FluQ::Input::Base>] inputs
+  def inputs
+    actors
+  end
+
+  # Listens to an input
+  # @param [Class<FluQ::Input::Base>] klass input class
+  # @param [multiple] args initialization arguments
+  def listen(klass, *args)
+    supervise klass, name, handlers, *args
+  end
+
+  # Registers a handler
+  # @param [Class<FluQ::Handler::Base>] klass handler class
+  # @param [multiple] args initialization arguments
+  def register(klass, *args)
+    handlers.push [klass, *args]
+  end
+
+  # @return [String] introspection
+  def inspect
+    "#<#{self.class.name}(#{name}) inputs: #{inputs.size}, handlers: #{handlers.size}>"
+  end
+
+end