on_put_record_result

in lib/kinesis_producer/library.rb [32:43]

• 11 lines of code
• 2 McCabe index (conditional complexity)

      def on_put_record_result(message)
        source_id = message.source_id
        result = message.put_record_result
        f = @futures.fetch(source_id)
        @futures.delete(source_id)
        if result.success
          f.set(result)
        else
          f.fail(StandardError.new(result.to_hash))
        end
      end