Packages

rafted_value

0.10.4
0.12.0 0.11.2 0.11.1 0.11.0 0.10.4 0.10.3 0.10.2 0.10.1 0.10.0 0.9.3 0.9.2 0.9.1 retired 0.9.0 0.8.0 0.7.3 0.7.2 0.7.1 0.7.0 0.6.0 0.5.0 0.4.0 0.3.2 0.3.1 0.3.0 0.2.1 0.2.0 0.1.10 0.1.9 0.1.8 0.1.7 0.1.6 0.1.5 0.1.4 0.1.3 0.1.2 0.1.1 0.1.0

Replicated and synchronized values wrapped by processes

HexDocs

Current section

Files

Jump to
Readme
37 Versions
1 Dependency
Dependants
Files
Activity
rafted_value lib rafted_value timer.ex
Raw

lib/rafted_value/timer.ex 

use Croma



defmodule RaftedValue.Timer do

  defun make(time :: non_neg_integer, msg :: any) :: reference do

    :erlang.send_after(time, self(), {:"$gen_cast", msg})

  end



  defun cancel(ref :: reference) :: :ok do

    case :erlang.cancel_timer(ref) do

      false ->

        receive do

          {:timeout, ^ref, _} -> :ok

        after

          0 -> :ok

        end

      _remaining_time -> :ok

    end

  end

end