Packages

exd

0.2.0
0.2.1 0.2.0 0.1.36 0.1.35 0.1.34 0.1.33 0.1.32 0.1.31 0.1.30 0.1.29 0.1.28 0.1.27 0.1.26 0.1.25 0.1.24 0.1.23 0.1.22 0.1.21 0.1.20 0.1.19 0.1.17 0.1.16 0.1.15 0.1.14 0.1.13 0.1.12 0.1.11 0.1.10 0.1.9 0.1.8 0.1.7 0.1.6 0.1.5 0.1.4 0.1.3 0.1.2 0.1.1 0.1.0

A few sentences (a paragraph) describing the project.

HexDocs

Current section

Files

Jump to
Readme
38 Versions
7 Dependencies
Dependants
Files
Activity
exd lib exd plugin list range.ex
Raw

lib/exd/plugin/list/range.ex 

defmodule Exd.Plugin.List.Range do

  @moduledoc """

  Multiply two numbers

  """

  use Exd.Plugin

  alias Exd.{Context, Record}



  @impl true

  def name do

    :range

  end



  @impl true

  def init(%Context{params: [min, max]} = context) do

    state = %{min: min, max: max}

    {:producer, state}

  end



  @impl true

  def handle_demand(demand, %{min: min, max: max} = state) when min < max do

    max = Enum.min([max, demand])

    produced =

      state.min..max

      |> Enum.to_list

      |> Enum.map(&Record.from(&1))



    new_state = %{state | min: min + length(produced)}

    if new_state.min >= new_state.max, do: GenStage.async_info(self(), :terminate)

    {:noreply, produced, new_state}

  end

  def handle_demand(_demand, state),

    do: {:stop, :normal, state}



end