Merge branch 'openapi/timelines' into 'develop'
[akkoma] / test / notification_test.exs
index 24e5f0c73d4d2e80c54200952166a397051404b8..4dfbc10190f97e2a5061d0c79ff26094229de6bd 100644 (file)
@@ -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)