Class: Queight::ChannelWrapper

Inherits:

SimpleDelegator

• Object
• SimpleDelegator
• Queight::ChannelWrapper

Defined in:

lib/queight/channel_wrapper.rb

Overview

Adds memoization of exchanges etc.

Instance Method Summary

• #exchange(*args) ⇒ Object
• #initialize(channel) ⇒ ChannelWrapper constructor

  A new instance of ChannelWrapper.

• #reset_cache! ⇒ Object

Constructor Details

#initialize(channel) ⇒ ChannelWrapper

Returns a new instance of ChannelWrapper.

# File 'lib/queight/channel_wrapper.rb', line 4

def initialize(channel)
  super(channel)
  reset_cache!
end

Instance Method Details

#exchange(*args) ⇒ Object

# File 'lib/queight/channel_wrapper.rb', line 13

def exchange(*args)
  @exchange_cache[args] ||= super
end

#reset_cache! ⇒ Object

# File 'lib/queight/channel_wrapper.rb', line 9

def reset_cache!
  @exchange_cache = {}
end