Current section
Files
Jump to
Current section
Files
lib/ip_mapper/producer.ex
defmodule IPMapper.Producer do
use GenStage
def start_link(ip_list) do
GenStage.start_link(__MODULE__, ip_list, name: __MODULE__)
end
def init(ip_list) do
{:producer, ip_list}
end
def handle_demand(demand, state) when demand > 0 do
{to_send, remaining} = Enum.split(state, demand)
{:noreply, to_send, remaining}
end
end