class Object

Public Instance Methods

echo(data) click to toggle source
# File lib/anyt/tests/subscriptions/perform_test.rb, line 12
def echo(data)
  transmit({response: data["text"]})
end
ping(data) click to toggle source
# File lib/anyt/tests/streams/stop_test.rb, line 10
def ping(data)
  ActionCable.server.broadcast data["name"], {reply: "pong"}
end
subscribed() click to toggle source
# File lib/anyt/tests/features/channel_state_test.rb, line 7
def subscribed
  self.user = {name: params["name"]}
  self.count = 1

  stream_from "state_counts"
end
tick() click to toggle source
# File lib/anyt/tests/features/channel_state_test.rb, line 14
def tick
  self.count += 2
  transmit({count: count, name: user[:name]})
end
unfollow(data) click to toggle source
# File lib/anyt/tests/streams/stop_test.rb, line 14
def unfollow(data)
  stop_stream_from data["name"]
end
unsubscribed() click to toggle source
# File lib/anyt/tests/features/channel_state_test.rb, line 19
def unsubscribed
  return unless params["notify_disconnect"]

  ActionCable.server.broadcast("state_counts", {data: "user left: #{user[:name]}"})
end