Packages

exd

0.1.21
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 query_runner join.ex
Raw

lib/exd/query_runner/join.ex 

defmodule Exd.Runner.Join do

  @moduledoc """

  From clause

  """



  @type option :: {:max_demand, integer()}

    | {:min_demand, integer()}

    | {:stages, integer()}



  @type options :: [option]



  @doc """

  Creates a new flow from source

  """

  @spec join(Flow.t, binary(), any(), options()) :: Flow.t

  def join(flow, namespace, specable, opts \\ []) do

    max_demand = Keyword.get(opts, :max_demand, 1)

    min_demand = Keyword.get(opts, :min_demand, 0)

    stages = Keyword.get(opts, :stages, 1)



    subscription_opts = [

      max_demand: max_demand,

      min_demand: min_demand,

      stages: stages

    ]



    # adapter_spec = Exd.Specable.to_spec(specable)

    adapter_spec = {Exd.Source.Function, fn: specable}

    source_opts = [adapter: adapter_spec, namespace: namespace]

    spec = {Exd.Mapper, source_opts}

    specs =  [{spec, subscription_opts}]



    flow

    |> Flow.through_specs(specs)

  end



end