Sha256: 8605a0103c2746a82445d5a08fb66af4c220dfc65b9050659a4548e99a5af99f
Contents?: true
Size: 517 Bytes
Versions: 4
Compression:
Stored size: 517 Bytes
Contents
prepend Actions
require 'async/websocket/server/rack'
require 'set'
$connections = Set.new
on 'connect' do |request|
response = Async::WebSocket::Server::Rack.open(request.env) do |connection|
$connections << connection
while message = connection.read
$connections.each do |connection|
puts "Server sending message: #{message.inspect}"
connection.write(message)
end
end
ensure
$connections.delete(connection)
end
Async.logger.info(self, request, response)
respond?(response)
end
Version data entries
4 entries across 4 versions & 1 rubygems