class Futurism::Channel
Public Instance Methods
receive(data)
click to toggle source
# File lib/futurism/channel.rb, line 17 def receive(data) resources = data.fetch_values("signed_params", "sgids", "signed_controllers", "urls", "broadcast_each") { |_key| Array.new(data["signed_params"].length, nil) }.transpose resolver = Resolver::Resources.new(resource_definitions: resources, connection: connection, params: @params) resolver.resolve do |selector, html, broadcast_each| cable_ready[stream_name].outer_html( selector: selector, html: html ) cable_ready.broadcast if broadcast_each end cable_ready.broadcast end
stream_name()
click to toggle source
# File lib/futurism/channel.rb, line 5 def stream_name ids = connection.identifiers.map { |identifier| send(identifier).try(:id) || send(identifier) } [ params[:channel], ids.select(&:present?).join(";") ].select(&:present?).join(":") end
subscribed()
click to toggle source
# File lib/futurism/channel.rb, line 13 def subscribed stream_from stream_name end