Packages

exd

0.1.2
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
4 Dependencies
Dependants
Files
Activity
exd lib exd sink.ex
Raw

lib/exd/sink.ex 

defmodule Exd.Sink do

  @moduledoc """

  Defines a source



  ## Options



    * `:adapter` - The source adapter module and options

    * `:concurrency` - The number of concurrent source connections



  ## Usage



      defmodule PersonSource do

        use Exd.Source,

          adapter: {

            Exd.Sources.File,

              file_path: "test/support/fixtures/people.json"

          }

      end

  """

  use GenStage



  def start_link(opts) do

    GenStage.start_link(__MODULE__, opts  )

  end



  @impl true

  def init(opts) do

    {adapter, adapter_opts} = Keyword.fetch!(opts, :adapter)

    {:ok, sink_state} = adapter.init(adapter_opts)

    {:consumer, {adapter, sink_state}}

  end



  @impl true

  def handle_events(events, _from, {adapter, sink_state}) do

    adapter.handle_into(events, sink_state)

    {:noreply, [], {adapter, sink_state}}

  end



end