X-Git-Url: http://git.squeep.com/?a=blobdiff_plain;f=test%2Fweb%2Fstreamer%2Fstreamer_test.exs;h=7166d6f0ba3d70a22405160965d2ade8ef9e4e12;hb=a802e07241e441189f85568ee9ca58508ab6d0d3;hp=b07a7373f6fcfa9586718673680ef55b5120bfb7;hpb=6ffbfdeeb2fc5ce7c2bf3a58950f5bf1f9a31e6f;p=akkoma

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)