Sha256: a34298ec9de12ae8f7fda9efaa99d7efe5b83195d411860b2a75b51fd0f09b8c
Contents?: true
Size: 552 Bytes
Versions: 1
Compression:
Stored size: 552 Bytes
Contents
require 'async_cable/version' require 'async_cable/errors' require 'async_cable/config' require 'async_cable/registry' require 'async_cable/connection' require 'async_cable/server' module AsyncCable def config @config ||= Config.new end def configure yield config end def broadcast(data) config.logger.debug { "#{name}.broadcast data=#{data.inspect}" } Registry.find.each { |conn| conn.transmit(data) } end module_function :configure, :config, :broadcast config # initialize config right away to prevent racing. end
Version data entries
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
async_cable-0.1.0 | lib/async_cable.rb |