sleep for 0.1 seconds if timer group is empty (#21 #22)

lib/graphite-api/client.rb

@@ -13,19 +13,21 @@ class Client
     def_delegator :buffer, :stream
 
     attr_reader :options, :buffer, :connectors, :mu
-    private     :options, :buffer, :connectors, :mu
+    private :options, :buffer, :connectors, :mu
 
     def initialize opt
       @options = build_options validate opt.clone
-      @buffer  = GraphiteAPI::Buffer.new options, timers
+      @buffer = GraphiteAPI::Buffer.new options, timers
       @connectors = GraphiteAPI::Connector::Group.new options
       @mu = Mutex.new
 
       timers.every(options[:interval], true, &method(:send_metrics!)) unless options[:direct]
     end
 
     def timers
-      @timers ||= Timers::Group.new.tap {|t| Thread.new { loop { t.wait } } }
+      @timers ||= Timers::Group.new.tap { |t| Thread.new { loop {
+        t.wait { |n| sleep(n.nil? ? 0.1 : [n, 0].max) }
+      } } }
     end
 
     # throw exception on Socket error
@@ -46,9 +48,9 @@ def metrics metric, time = nil, aggregation_method = nil
     def increment(*keys)
       opt = {}
       opt.merge! keys.pop if keys.last.is_a? Hash
-      by = opt.fetch(:by,1)
-      time = opt.fetch(:time,Time.now)
-      metric = keys.inject({}) {|h,k| h.merge k => by }
+      by = opt.fetch(:by, 1)
+      time = opt.fetch(:time, Time.now)
+      metric = keys.inject({}) { |h, k| h.merge k => by }
       metrics(metric, time)
     end
 

lib/graphite-api/version.rb

@@ -1,3 +1,3 @@
 module GraphiteAPI
-  VERSION = "1.1.0"
+  VERSION = "1.1.1"
 end