Sha256: 522729385794a716ed438085dc8c4fe0212c85eddc393a4a7e4420a54812485d
Contents?: true
Size: 839 Bytes
Versions: 31
Compression:
Stored size: 839 Bytes
Contents
require 'websocket/driver'
module ActionCable
module Connection
# Wrap the real socket to minimize the externally-presented API
class WebSocket
def initialize(env, event_target, event_loop, client_socket_class, protocols: ActionCable::INTERNAL[:protocols])
@websocket = ::WebSocket::Driver.websocket?(env) ? client_socket_class.new(env, event_target, event_loop, protocols) : nil
end
def possible?
websocket
end
def alive?
websocket && websocket.alive?
end
def transmit(data)
websocket.transmit data
end
def close
websocket.close
end
def protocol
websocket.protocol
end
def rack_response
websocket.rack_response
end
protected
attr_reader :websocket
end
end
end
Version data entries
31 entries across 31 versions & 4 rubygems