Packages

exd

0.1.23
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 source adapter function.ex
Raw

lib/exd/source/adapter/function.ex 

defmodule Exd.Source.Function do

  @moduledoc """

  A list based source



  ## Options



    * `:value` - The list itself

  """

  use Exd.Source.Adapter



  defstruct [

    fn: nil,

    done: false

  ]



  @impl true

  def init([{:fn, function} | _rest]) do

    {

      :ok,

      %__MODULE__{

        fn: function

      }

    }

  end



  def handle_from(demand, %{done: true} = _state), do: :done

  def handle_from(demand, %{done: false, fn: func} = state) do

    produced = func.(%{})

    {:ok, produced, %__MODULE__{state | done: true}}

  end



  # @impl true

  def handle_join(records, state) do

    results = state.fn.(records)

    {:ok, results}

  end



end