Packages

alf

0.1.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 producer.ex
Raw

lib/components/producer.ex 

defmodule ALF.Components.Producer do

  use GenStage



  defstruct name: :producer,

            pid: nil,

            pipe_module: nil,

            pipeline_module: nil,

            subscribe_to: []



  def start_link(_args) do

    GenStage.start_link(__MODULE__, nil)

  end



  def init(_), do: {:producer, []}



  def handle_demand(_demand, [ip | ips]) do

    {:noreply, [ip], ips}

  end



  def handle_demand(_demand, []) do

    {:noreply, [], []}

  end



  def handle_cast([new_ip | new_ips], ips) do

    {:noreply, [new_ip], ips ++ new_ips}

  end



  def handle_cast([], ips) do

    {:noreply, [], ips}

  end

end