Contents

require_relative './constants'
require_relative './helpers'
require_relative './message'

module Deepstream
  class ErrorHandler
    attr_reader :error

    def initialize(client)
      @client = client
      @error = nil
    end

    def on_error(message)
      @error =
        if message.is_a?(Message)
          message.topic == TOPIC::ERROR ? message.data : Helpers.to_type(message.data.last)
        else
          message
        end
      puts "#{@error}\n" unless @client.options[:debug]
    end

    def on_exception(exception)
      raise exception if @client.options[:debug]
      puts "\n#{exception.message}\n#{exception.backtrace}\n"
    end
  end
end

Version data entries

9 entries across 9 versions & 1 rubygems

Version	Path
deepstream-1.0.10	lib/deepstream/error_handler.rb
deepstream-1.0.9	lib/deepstream/error_handler.rb
deepstream-1.0.8	lib/deepstream/error_handler.rb
deepstream-1.0.7	lib/deepstream/error_handler.rb
deepstream-1.0.6	lib/deepstream/error_handler.rb
deepstream-1.0.5	lib/deepstream/error_handler.rb
deepstream-1.0.4	lib/deepstream/error_handler.rb
deepstream-1.0.3	lib/deepstream/error_handler.rb
deepstream-1.0.2	lib/deepstream/error_handler.rb