Packages

grains

0.3.1
1.7.1 1.7.0 1.6.0 1.5.1 1.5.0 1.4.1 1.4.0 1.3.1 1.3.0 1.2.0 1.1.1 1.1.0 1.0.0 0.5.0 0.5.0-rc.3 0.5.0-rc.2 0.5.0-rc.1 0.5.0-rc.0 0.3.7 0.3.6 0.3.5 0.3.4 0.3.3 0.3.2 0.3.1 0.3.0 0.2.0 0.1.2 0.1.1 0.1.0

A framework to implement process data flows using declarative flow graphs.

HexDocs

Current section

Files

Jump to
Readme
30 Versions
0 Dependencies
Dependants
Files
Activity
grains lib grains timer.ex
Raw

lib/grains/timer.ex 

defmodule Grains.Timer do

  @moduledoc """

  A periodic timer.

  """



  use Grains.GenGrain



  defmodule State do

    @enforce_keys [:period]

    defstruct @enforce_keys ++ [from: nil, with_timestamps: false]

  end



  def name(left, grain) do

    Module.concat([left, grain, Timer])

  end



  def init(opts) do

    state = struct!(State, opts)

    {:ok, _} = :timer.send_interval(state.period, :tick)



    {:ok, state}

  end



  def handle_info(:tick, state) do

    pull()



    {:noreply, state}

  end



  def handle_push(msg, _from, state = %{with_timestamps: true}) do

    now = DateTime.utc_now()

    :ok = push({now, msg})

    {:noreply, state}

  end



  def handle_push(msg, _from, state) do

    :ok = push(msg)

    {:noreply, state}

  end

end