formatting
authorrinpatch <rinpatch@sdf.org>
Sun, 15 Dec 2019 22:37:33 +0000 (01:37 +0300)
committerrinpatch <rinpatch@sdf.org>
Sun, 15 Dec 2019 22:37:33 +0000 (01:37 +0300)
test/web/streamer/streamer_test.exs

index b07a7373f6fcfa9586718673680ef55b5120bfb7..7166d6f0ba3d70a22405160965d2ade8ef9e4e12 100644 (file)
@@ -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)