Skip to content

Commit af92dba

Browse files
committed
Add the chatroom
1 parent 4cb1eff commit af92dba

File tree

1 file changed

+16
-0
lines changed

1 file changed

+16
-0
lines changed

lib/watercooler.ex

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,2 +1,18 @@
11
defmodule Watercooler do
2+
@group :watercooler
3+
4+
def publish(message) do
5+
:ok = :pg2.create(@group)
6+
for client <- :pg2.get_members(@group) do
7+
send(client, {@group, message})
8+
end
9+
10+
{:ok, message}
11+
end
12+
13+
def listen() do
14+
:ok = :pg2.create(@group)
15+
:ok = :pg2.join(@group, self())
16+
{:ok, @group}
17+
end
218
end

0 commit comments

Comments
 (0)