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

lib/components/consumer.ex 

defmodule ALF.Components.Consumer do

  use GenStage



  alias ALF.{ErrorIP, IP, Manager}



  defstruct name: :consumer,

            manager_name: nil,

            pid: nil,

            pipe_module: nil,

            subscribe_to: [],

            pipeline_module: nil



  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([ip], _from, state) when is_struct(ip, IP) or is_struct(ip, ErrorIP) do

    Manager.result_ready(state.manager_name, ip)



    {:noreply, [], state}

  end

end