class Restforce::Concerns::Streaming::ReplayExtension

def replay_id(channel)
  handler = @replay_handlers[channel]
  if handler.respond_to?(:[]) && !handler.is_a?(Integer)
    # Ask for the latest replayId for this channel
    handler[channel]
  else
    # Just pass it along
    handler
  end
end