aboutsummaryrefslogtreecommitdiff
path: root/test/notification_test.exs
diff options
context:
space:
mode:
authorrinpatch <rinpatch@sdf.org>2020-05-12 17:02:57 +0000
committerrinpatch <rinpatch@sdf.org>2020-05-12 17:02:57 +0000
commit2b18b8a2634dbf6529cb0aab831db9c1a2efd2db (patch)
tree4b9ccae8b47bd93dd504fe28cee4a84accd196c6 /test/notification_test.exs
parent24c8c13640342ae6d86070dafb041339eee016f3 (diff)
parent68cca29dcf87d68be82c0287f3803847abd54353 (diff)
downloadpleroma-2b18b8a2634dbf6529cb0aab831db9c1a2efd2db.tar.gz
Merge branch 'streamer-get-topic' into 'develop'
Expand and authorize streams in Streamer directly See merge request pleroma/pleroma!2519
Diffstat (limited to 'test/notification_test.exs')
-rw-r--r--test/notification_test.exs4
1 files changed, 2 insertions, 2 deletions
diff --git a/test/notification_test.exs b/test/notification_test.exs
index 24e5f0c73..4dfbc1019 100644
--- a/test/notification_test.exs
+++ b/test/notification_test.exs
@@ -170,13 +170,13 @@ defmodule Pleroma.NotificationTest do
task =
Task.async(fn ->
- Streamer.add_socket("user", user)
+ Streamer.get_topic_and_add_socket("user", user)
assert_receive {:render_with_user, _, _, _}, 4_000
end)
task_user_notification =
Task.async(fn ->
- Streamer.add_socket("user:notification", user)
+ Streamer.get_topic_and_add_socket("user:notification", user)
assert_receive {:render_with_user, _, _, _}, 4_000
end)