123456789_123456789_123456789_123456789_123456789_

Module: ActiveSupport::Messages::Rotator

Do not use. This module is for internal use only.
Relationships & Source Files
Extension / Inclusion / Inheritance Descendants
Included In:
::ActiveSupport::MessageEncryptor, ::ActiveSupport::MessageVerifier
Defined in: activesupport/lib/active_support/messages/rotator.rb

Instance Method Summary

Instance Method Details

#build_rotation(*args, **options) (private)

[ GitHub ] 

  


# File 'activesupport/lib/active_support/messages/rotator.rb', line 54



def build_rotation(*args, **options)
  self.class.new(*args, *@args.drop(args.length), **@options, **options)
end


  








  

    #catch_rotation_error(&block)   (private)
  

  [ GitHub ]


  

  


# File 'activesupport/lib/active_support/messages/rotator.rb', line 58



def catch_rotation_error(&block)
  error = catch :invalid_message_format do
    error = catch :invalid_message_serialization do
      return [nil, block.call]
    end
    return [:invalid_message_serialization, error]
  end
  [:invalid_message_format, error]
end


  








  

    #fall_back_to(fallback)  
  

  [ GitHub ]


  

  


# File 'activesupport/lib/active_support/messages/rotator.rb', line 23



def fall_back_to(fallback)
  @rotations << fallback
  self
end


  








  

    #initialize(*args, on_rotation: nil, **options)  
  

  [ GitHub ]


  

  


# File 'activesupport/lib/active_support/messages/rotator.rb', line 6



def initialize(*args, on_rotation: nil, **options)
  super(*args, **options)
  @args = args
  @options = options
  @rotations = []
  @on_rotation = on_rotation
end


  








  

    #initialize_dup  
  

  [ GitHub ]


  

  


# File 'activesupport/lib/active_support/messages/rotator.rb', line 48



def initialize_dup(*)
  super
  @rotations = @rotations.dup
end


  








  

    #on_rotation(&on_rotation)  
  

  [ GitHub ]


  

  


# File 'activesupport/lib/active_support/messages/rotator.rb', line 18



def on_rotation(&on_rotation)
  @on_rotation = on_rotation
  self
end


  








  

    #read_message(message, on_rotation: @on_rotation, **options)  
  

  [ GitHub ]


  

  


# File 'activesupport/lib/active_support/messages/rotator.rb', line 28



def read_message(message, on_rotation: @on_rotation, **options)
  if @rotations.empty?
    super(message, **options)
  else
    thrown, error = catch_rotation_error do
      return super(message, **options)
    end

    @rotations.each do |rotation|
      catch_rotation_error do
        value = rotation.read_message(message, **options)
        on_rotation&.call
        return value
      end
    end

    throw thrown, error
  end
end


  








  

    #rotate(*args, **options)  
  

  [ GitHub ]


  

  


# File 'activesupport/lib/active_support/messages/rotator.rb', line 14



def rotate(*args, **options)
  fall_back_to build_rotation(*args, **options)
end