Commit eae65e32 authored by rinpatch's avatar rinpatch

formatting

parent 6ffbfdee
......@@ -121,7 +121,7 @@ test "it sends follow activities to the 'user:notification' stream", %{
} 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 @@ test "it sends to public" do
task =
Task.async(fn ->
assert_receive {:text, _}, @streamer_timeout
assert_receive {:text, _}, @streamer_timeout
end)
fake_socket = %StreamerSocket{
......@@ -559,11 +559,11 @@ test "it sends conversation update to the 'direct' stream when a message is dele
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)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment