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