Packages

exd

0.1.14
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 bus.ex
Raw

lib/exd/source/adapter/bus.ex 

defmodule Exd.Source.Bus do

  @moduledoc """

  A list based source



  ## Options



    * `:value` - The list itself

  """

  use Exd.Source.Adapter

  alias Exd.Source.Bus.Broker



  defstruct [

    topic: nil,

    broker: nil,

    shadows: []

  ]



  @impl true

  def init([{:topic, topic} | rest]) do

    {:ok, broker} = Broker.start_link(parent: self())

    {

      :ok,

      %__MODULE__{

        topic: topic,

        broker: broker

      }

    }

  end



  @impl true

  def handle_from(demand, state) do

    {shadows, buffered} = Enum.split(state.shadows, demand)

    produced =

      for shadow <- shadows do

        EventBus.fetch_event(shadow)

      end

    {:ok, %__MODULE__{state | shadows: buffered}}

  end



  @impl true

  def handle_info({:record_received, event_id} = shadow, _, state) do

    {:noreply, :ok, %__MODULE__{state | shadows: state.shadows ++ [shadow]}}

  end



end