on_metrics_response

in lib/kinesis_producer/library.rb [44:51]

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

      def on_metrics_response(message)
        source_id = message.source_id
        response = message.metrics_response
        f = @futures.fetch(source_id)
        @futures.delete(source_id)
        f.set(response.metrics)
      end