Sha256: 49933fa84ee458c1e25070911b16542d6c9849768e7e4de875d06ae11e2daab5
Contents?: true
Size: 667 Bytes
Versions: 14
Compression:
Stored size: 667 Bytes
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}\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
14 entries across 14 versions & 1 rubygems