Packages

exd

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

lib/exd/repo.ex 



defmodule Exd.Repo do

  @moduledoc """

  Repository for sources

  """

  alias Exd.QueryRunner



  defmacro __using__(_opts) do

    quote do

      use GenServer



      # Client



      def start_link(opts \\ []) do

        GenServer.start_link(__MODULE__, opts, name: __MODULE__)

      end



      def stream(query) do

        GenServer.call(__MODULE__, {:stream, query})

      end



      # Server



      @impl true

      def init(_) do

        {:ok, nil}

      end



      @impl true

      def handle_call({:stream, query}, _from, state) do

        {:ok, __coordinator} =

          query

          |> QueryRunner.stream

          |> Flow.start_link

        {:reply, :ok, state}

      end



    end

  end



  @doc """

  Returns a stream of sourced records

  """

  def stream(query, opts \\ []) do

    QueryRunner.stream(query)

  end



end