class Slack::RealTime::Socket
Attributes
driver[R]
logger[R]
options[RW]
url[RW]
Public Class Methods
new(url, options = {})
click to toggle source
# File lib/slack/real_time/socket.rb, line 10 def initialize(url, options = {}) @url = url @options = options @driver = nil @logger = options.delete(:logger) || Slack::RealTime::Config.logger || Slack::Config.logger end
Public Instance Methods
close()
click to toggle source
# File lib/slack/real_time/socket.rb, line 56 def close @driver = nil end
connect!() { |driver| ... }
click to toggle source
# File lib/slack/real_time/socket.rb, line 27 def connect! return if connected? connect logger.debug("#{self.class}##{__method__}") { driver.class } yield driver if block_given? end
connected?()
click to toggle source
# File lib/slack/real_time/socket.rb, line 40 def connected? !driver.nil? end
disconnect!()
click to toggle source
# File lib/slack/real_time/socket.rb, line 36 def disconnect! driver.close end
send_data(message)
click to toggle source
# File lib/slack/real_time/socket.rb, line 17 def send_data(message) logger.debug("#{self.class}##{__method__}") { message } case message when Numeric then driver.text(message.to_s) when String then driver.text(message) when Array then driver.binary(message) else false end end
start_async(_client)
click to toggle source
@return [#join]
# File lib/slack/real_time/socket.rb, line 52 def start_async(_client) raise NotImplementedError, "Expected #{self.class} to implement #{__method__}." end
start_sync(client)
click to toggle source
# File lib/slack/real_time/socket.rb, line 44 def start_sync(client) thread = start_async(client) thread.join if thread rescue Interrupt thread.exit if thread end
Protected Instance Methods
addr()
click to toggle source
# File lib/slack/real_time/socket.rb, line 62 def addr URI(url).host end
connect()
click to toggle source
# File lib/slack/real_time/socket.rb, line 81 def connect raise NotImplementedError, "Expected #{self.class} to implement #{__method__}." end
port()
click to toggle source
# File lib/slack/real_time/socket.rb, line 70 def port case (uri = URI(url)).scheme when 'wss'.freeze, 'https'.freeze URI::HTTPS::DEFAULT_PORT when 'ws', 'http'.freeze URI::HTTP::DEFAULT_PORT else uri.port end end
secure?()
click to toggle source
# File lib/slack/real_time/socket.rb, line 66 def secure? port == URI::HTTPS::DEFAULT_PORT end