Testowanie kodu asynchronicznego w Elixir

Question

Chcę przetestować funkcję, która korzysta Task.async

Aby uczynić mój test zdać, muszę zrobić to spać przez 100ms przed twierdzeniami, w przeciwnym razie proces testowy zostanie zabity przed async zadanie jest wykonywane.

Czy istnieje lepszy sposób?

edytować, dodając próbki kodu:

Kod Chciałbym przetestować (w przybliżeniu):

def search(params) do 
    RateLimiter.rate_limit(fn -> 
    parsed_params = ExTwitter.Parser.parse_request_params(params) 
    json = ExTwitter.API.Base.request(:get, "1.1/search/tweets.json", parsed_params) 
    Task.async(fn -> process_search_output(json) end) 
    new_max_id(json) 
    end) 
end 

a test już pisałem (działa tylko z wezwaniem do spania)

test "processes and store tweets" do 
    with_mock ExTwitter.API.Base, [request: fn(_,_,_) -> json_fixture end] do 
    with_mock TwitterRateLimiter, [rate_limit: fn(fun) -> fun.() end] do 
     TSearch.search([q: "my query"]) 
     :timer.sleep(100) 
     # assertions 
     assert called TStore.store("some tweet from my fixtures") 
     assert called TStore.store("another one") 
    end 
    end 
end 

Answer 1

Ponieważ pytanie jest nieco niejasne, udzielę ogólnej odpowiedzi tutaj. Zwykłą techniką jest monitorowanie procesu i oczekiwanie na wiadomość w dół. Coś takiego:

task = Task.async(fn -> "foo" end) 
ref = Process.monitor(task.pid) 
assert_receive {:DOWN, ^ref, :process, _, :normal}, 500 

Kilka ważnych rzeczy:

• Piąty element krotki jest powód wyjście. Zapewniam, że wyjście z zadania to :normal. Zmień to odpowiednio, jeśli spodziewasz się kolejnego wyjścia.

• Druga wartość w assert_receive to limit czasu. 500 milisekund wyda się rozsądną kwotą, biorąc pod uwagę, że obecnie masz sen 100 ms.

Answer 2

Kiedy nie można używać podejścia Jose udziałem assert_receive, używam małego pomocnika wielokrotnie zrobić twierdzenie/uśpienia, aż do przełęczy twierdzenie czy wreszcie czas na zewnątrz.

Oto moduł pomocnik

defmodule TimeHelper do 

    def wait_until(fun), do: wait_until(500, fun) 

    def wait_until(0, fun), do: fun.() 

    def wait_until(timeout, fun) defo 
    try do 
     fun.() 
    rescue 
     ExUnit.AssertionError -> 
     :timer.sleep(10) 
     wait_until(max(0, timeout - 10), fun) 
    end 
    end 

end 

Może być stosowany tak w dawnej przykład:

TSearch.search([q: "my query"]) 
wait_until fn -> 
    assert called TStore.store("some tweet from my fixtures") 
    assert called TStore.store("another one") 
end