class SalesforceStreamer::ReplayIdErrorExtension

Constants

REPLAY_ERROR_REGEX

Public Instance Methods

incoming(message, callback) click to toggle source
# File lib/salesforce_streamer/replay_id_error_extension.rb, line 5
def incoming(message, callback)
  if message['error']&.match?(REPLAY_ERROR_REGEX)
    fail ReplayIdError, message['error']
  end

  callback.call message
end