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 dead_end.ex
Raw

lib/components/dead_end.ex 

defmodule ALF.Components.DeadEnd do

  use ALF.Components.Basic



  defstruct name: nil,

            pid: nil,

            pipe_module: nil,

            pipeline_module: nil,

            subscribe_to: [],

            subscribers: []



  def start_link(%__MODULE__{} = state) do

    GenStage.start_link(__MODULE__, state)

  end



  def init(state) do

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

  end



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

    {:noreply, [], state}

  end

end