|
|
@ -24,7 +24,7 @@ defmodule Indexer.TokenTransfer.Uncataloged.WorkerTest do |
|
|
|
test "sends shutdown to supervisor" do |
|
|
|
test "sends shutdown to supervisor" do |
|
|
|
state = %{task_ref: nil, block_numbers: [], sup_pid: self()} |
|
|
|
state = %{task_ref: nil, block_numbers: [], sup_pid: self()} |
|
|
|
Task.async(fn -> Worker.handle_info(:scan, state) end) |
|
|
|
Task.async(fn -> Worker.handle_info(:scan, state) end) |
|
|
|
assert_receive {_, _, {:terminate, :normal}} |
|
|
|
assert_receive {_, _, {:terminate, :normal}}, 200 |
|
|
|
end |
|
|
|
end |
|
|
|
|
|
|
|
|
|
|
|
test "sends message to self when uncataloged token transfers are found" do |
|
|
|
test "sends message to self when uncataloged token transfers are found" do |
|
|
|