       test "terminates outer effect" do
         stream =
           1..4
-          |> Stream.transform(fn -> :ok end,
-                              fn x, acc -> {[x], acc} end,
-                              fn _ -> Process.put(:stream_transform, true) end)
+          |> Stream.transform(fn -> :ok end, fn x, acc -> {[x], acc} end, fn _ ->
+               Process.put(:stream_transform, true)
+             end)
           |> Task.async_stream(&sleep/1, @opts)
 
         Process.put(:stream_transform, false)


    assert {__MODULE__, :wait_and_send, 2} === :proc_lib.translate_initial_call(pid)

    send pid, true
    assert_receive :done
  end


Code.require_file("test_helper.exs", __DIR__)

defmodule TaskTest do
  use ExUnit.Case
