Packages

alf

0.2.0
0.12.1 0.12.0 0.11.0 0.10.0 0.9.5 0.9.4 0.9.3 0.9.2 0.9.1 0.9.0 0.8.5 0.8.4 0.8.3 0.8.2 0.8.1 0.8.0 0.7.1 0.7.0 0.6.0 0.5.0 0.4.1 0.4.0 0.3.1 0.3.0 0.2.0 0.1.0

Flow-based Application Layer Framework

HexDocs

Current section

Files

Jump to
Readme
26 Versions
1 Dependency
Dependants
Files
Activity
alf lib components goto_point.ex
Raw

lib/components/goto_point.ex 

defmodule ALF.Components.GotoPoint do

  use ALF.Components.Basic



  defstruct name: nil,

            pid: nil,

            subscribe_to: [],

            subscribers: [],

            pipe_module: nil,

            pipeline_module: nil



  def start_link(%__MODULE__{} = state) do

    GenStage.start_link(__MODULE__, state)

  end



  def init(state) do

    {:producer_consumer, %{state | pid: self()}, subscribe_to: state.subscribe_to}

  end



  def handle_events([%ALF.IP{} = ip], _from, %__MODULE__{} = state) do

    ip = %{ip | history: [{state.name, ip.datum} | ip.history]}

    {:noreply, [ip], state}

  end



  def handle_call({:goto, %ALF.IP{} = ip}, _from, %__MODULE__{} = state) do

    ip = %{ip | history: [{state.name, ip.datum} | ip.history]}

    {:reply, :ok, [ip], state}

  end

end