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