diff options
| author | rinpatch <rinpatch@sdf.org> | 2019-12-16 01:37:33 +0300 |
|---|---|---|
| committer | rinpatch <rinpatch@sdf.org> | 2019-12-16 01:37:33 +0300 |
| commit | eae65e3216cb43f97e58ace7e0a57919332de8b8 (patch) | |
| tree | 8226a7812ea95f1f97939b75278ed2b721500d0b | |
| parent | 6ffbfdeeb2fc5ce7c2bf3a58950f5bf1f9a31e6f (diff) | |
| download | pleroma-eae65e3216cb43f97e58ace7e0a57919332de8b8.tar.gz | |
formatting
| -rw-r--r-- | test/web/streamer/streamer_test.exs | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/test/web/streamer/streamer_test.exs b/test/web/streamer/streamer_test.exs index b07a7373f..7166d6f0b 100644 --- a/test/web/streamer/streamer_test.exs +++ b/test/web/streamer/streamer_test.exs @@ -121,7 +121,7 @@ defmodule Pleroma.Web.StreamerTest do } do user2 = insert(:user) task = Task.async(fn -> assert_receive {:text, _}, @streamer_timeout end) - + Process.sleep(@streamer_start_wait) Streamer.add_socket( @@ -143,7 +143,7 @@ defmodule Pleroma.Web.StreamerTest do task = Task.async(fn -> - assert_receive {:text, _}, @streamer_timeout + assert_receive {:text, _}, @streamer_timeout end) fake_socket = %StreamerSocket{ @@ -559,11 +559,11 @@ defmodule Pleroma.Web.StreamerTest do task = Task.async(fn -> - assert_receive {:text, received_event}, @streamer_timeout assert %{"event" => "delete", "payload" => _} = Jason.decode!(received_event) assert_receive {:text, received_event}, @streamer_timeout + assert %{"event" => "conversation", "payload" => received_payload} = Jason.decode!(received_event) |