Packages

gust_py

0.1.3
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

Python DAG support for Gust

HexDocs

Current section

Files

Jump to
Readme
11 Versions
1 Dependency
Dependants
Files
Activity
gust_py lib gust_py task_messenger.ex
Raw

lib/gust_py/task_messenger.ex 

defmodule GustPy.TaskMessenger do

  @moduledoc false



  @type done_message :: {:result, term()} | {:error, term()}



  @callback decode(binary()) :: {:ok, map()} | {:error, term()}

  @callback handle_next(map()) :: :noreply | {:reply, map()} | {:done, done_message()}

  @callback reply(term(), map()) :: :ok



  def decode(data), do: impl().decode(data)

  def handle_next(msg), do: impl().handle_next(msg)

  def reply(target, payload), do: impl().reply(target, payload)



  defp impl, do: Application.get_env(:gust_py, :task_messenger, GustPy.TaskMessenger.JSON)

end