Packages

piazza_core

0.3.4
0.3.8 0.3.7 0.3.6 0.3.5 0.3.4 0.3.3 0.3.2 0.3.1 0.3.0 0.2.9 0.2.8 0.2.7 0.2.6 0.2.5 0.2.4 0.2.3 0.2.2 0.2.1 0.2.0 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

Simple building blocks for building elixir web apps

HexDocs

Current section

Files

Jump to
Readme
29 Versions
5 Dependencies
Dependants
Files
Activity
piazza_core lib pubsub consumer.ex
Raw

lib/pubsub/consumer.ex 

defmodule Piazza.PubSub.Consumer do

  defmacro __using__(broadcaster: broadcaster, max_demand: demand) do

    quote do

      use ConsumerSupervisor



      def start_link(arg) do

        ConsumerSupervisor.start_link(__MODULE__, arg)

      end



      def init(_arg) do

        children = [%{id: Piazza.Consumers.Worker, start: {Piazza.Consumers.Worker, :start_link, [__MODULE__]}, restart: :temporary}]

        opts = [strategy: :one_for_one, subscribe_to: [{unquote(broadcaster), max_demand: unquote(demand)}]]

        ConsumerSupervisor.init(children, opts)

      end

    end

  end

end



defmodule Piazza.Consumers.Worker do

  def start_link(handler, event) do

    Task.start_link(fn ->

      handler.handle_event(event)

    end)

  end

end