Contents

class TD::UpdateHandler
  include Concurrent::Async

  attr_reader :update_type, :extra

  def initialize(update_type, extra = nil, disposable: false, &action)
    super()

    @action = action
    @update_type = update_type
    @extra = extra
    @disposable = disposable
  end

  def run(update)
    action.call(update)
  rescue StandardError => e
    warn("Uncaught exception in handler #{self}: #{e.message}")
    raise
  end

  def match?(update, extra = nil)
    update.is_a?(update_type) && (self.extra.nil? || self.extra == extra)
  end

  def disposable?
    disposable
  end

  def to_s
    "TD::UpdateHandler (#{update_type}#{": #{extra}" if extra})#{' disposable' if disposable?}"
  end

  alias inspect to_s

  private

  attr_reader :action, :disposable
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
tdlib-ruby-3.1.0	lib/tdlib/update_handler.rb
tdlib-ruby-3.0.2	lib/tdlib/update_handler.rb
tdlib-ruby-3.0.1	lib/tdlib/update_handler.rb
tdlib-ruby-3.0.0	lib/tdlib/update_handler.rb