summaryrefslogtreecommitdiff
path: root/test/notification_test.exs
diff options
context:
space:
mode:
authorhref <href@random.sh>2020-05-12 18:04:47 +0200
committerhref <href@random.sh>2020-05-12 18:04:47 +0200
commite6d8cacf2de4ba48b881a390b0ba4582981d17a5 (patch)
tree1535a972c930e5cad4b2ca8d18a3101a1845394e /test/notification_test.exs
parentfdc9ac88976c229288052cd66cda6b37e3887200 (diff)
downloadpleroma-e6d8cacf2de4ba48b881a390b0ba4582981d17a5.tar.gz
pleroma-e6d8cacf2de4ba48b881a390b0ba4582981d17a5.zip
Expand and authorize streams in Streamer directly
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)