Packages

quickbeam

0.6.0
0.10.20 0.10.19 0.10.18 0.10.17 0.10.16 0.10.15 0.10.14 0.10.13 0.10.12 0.10.11 0.10.10 0.10.9 0.10.8 0.10.6 0.10.5 0.10.4 0.10.3 0.10.2 0.10.1 0.10.0 0.9.0 0.8.1 0.8.0 0.7.1 0.7.0 0.6.1 0.6.0 0.5.0 0.3.1 0.3.0 0.2.0 0.1.0

JavaScript runtime for the BEAM — Web APIs backed by OTP, native DOM, and a built-in TypeScript toolchain.

HexDocs

Current section

Files

Jump to
Readme
32 Versions
5 Dependencies
Dependants
Files
Activity
quickbeam lib quickbeam broadcast_channel.ex
Raw

lib/quickbeam/broadcast_channel.ex 

defmodule QuickBEAM.BroadcastChannel do

  @moduledoc false



  @scope QuickBEAM.BroadcastChannel



  def join([name], caller) do

    :pg.join(@scope, name, caller)

    :ok

  end



  def post([name, message], caller) do

    for pid <- :pg.get_members(@scope, name), pid != caller do

      send(pid, {:broadcast_message, name, message})

    end



    :ok

  end



  def leave([name], caller) do

    :pg.leave(@scope, name, caller)

    :ok

  end

end