Packages

grains

1.5.0
1.7.1 1.7.0 1.6.0 1.5.1 1.5.0 1.4.1 1.4.0 1.3.1 1.3.0 1.2.0 1.1.1 1.1.0 1.0.0 0.5.0 0.5.0-rc.3 0.5.0-rc.2 0.5.0-rc.1 0.5.0-rc.0 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.0 0.1.2 0.1.1 0.1.0

A framework to implement process data flows using declarative flow graphs.

HexDocs

Current section

Files

Jump to
Readme
30 Versions
0 Dependencies
Dependants
Files
Activity
grains lib grains support subscriber.ex
Raw

lib/grains/support/subscriber.ex 

defmodule Grains.Support.Subscriber do

  @moduledoc """

  A grain to pull message and forward pushed messages to a subscribing process.



  This grain is meant for testing purposes, where the incoming messages

  should be forwarded to the test process.

  """



  use Grains.GenGrain



  defmodule State do

    @enforce_keys [:subscriber]

    defstruct @enforce_keys ++ [with_tag: false]

  end



  @impl true

  def init(args) do

    {:ok, struct!(State, args)}

  end



  @impl true

  def handle_push(msg, _from, state) do

    send(state.subscriber, msg)

    {:noreply, state}

  end



  @impl true

  def handle_cast(:pull, state = %State{with_tag: false}) do

    pull()

    {:noreply, state}

  end



  def handle_cast(:pull, state = %State{with_tag: tag}) do

    pull_with_tag(tag)

    {:noreply, state}

  end



  def handle_cast({:pull, tag}, state) do

    pull_with_tag(tag)

    {:noreply, state}

  end

end