get_metrics

in lib/kinesis_producer/library.rb [89:96]

• 7 lines of code
• 1 McCabe index (conditional complexity)

    def get_metrics(options = {})
      f = Concurrent::IVar.new
      id = add_message(:metrics_request, KinesisProducer::Protobuf::MetricsRequest.new(options))
      @futures[id] = f
      f.wait
      f.value
    end