Contents

require 'deepstream/constants'
require 'deepstream/helpers'
require 'deepstream/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
    end

    def on_exception(exception)
      raise exception if @client.options[:debug]
      puts exception.message
      puts exception.backtrace
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
deepstream-0.2.0	lib/deepstream/error_handler.rb