actioncable/test/client/echo_channel.rb


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

class EchoChannel < ActionCable::Channel::Base
  def subscribed
    stream_from "global"
  end

  def ding(data)
    transmit(dong: data['message'])
  end

  def delay(data)
    sleep 1
    transmit(dong: data['message'])
  end

  def bulk(data)
    ActionCable.server.broadcast "global", wide: data['message']
  end
end