Packages

tigerbeetlex

0.16.47
0.16.78 0.16.77 0.16.76 0.16.75 0.16.73 0.16.72 0.16.70 0.16.69 0.16.68 0.16.67 0.16.66 0.16.65 0.16.64 0.16.63 0.16.62 0.16.61 0.16.60 0.16.59 0.16.58 0.16.57 0.16.56 0.16.55 0.16.54 0.16.53 0.16.52 0.16.51 0.16.50 0.16.48 0.16.47 0.16.46 0.16.45 0.16.44 0.16.43 0.16.42 0.16.41

Elixir client for TigerBeetle, the financial transactions database.

HexDocs

Current section

Files

Jump to
Readme
35 Versions
3 Dependencies
Dependants
Files
Activity
tigerbeetlex lib tigerbeetlex receiver.ex
Raw

lib/tigerbeetlex/receiver.ex 

defmodule TigerBeetlex.Receiver do

  @moduledoc false



  use GenServer



  alias TigerBeetlex.Client

  alias TigerBeetlex.Response



  defstruct [

    :client,

    :pending_requests

  ]



  def start_link(client_ref) do

    GenServer.start_link(__MODULE__, client_ref)

  end



  @impl true

  def init(client) do

    {:ok, %{client: client, pending_requests: %{}}}

  end



  @impl true

  def handle_call({operation, payload}, from, state) do

    case apply(Client, operation, [state.client, payload]) do

      {:ok, ref} ->

        {:noreply, %{state | pending_requests: Map.put(state.pending_requests, ref, from)}}



      {:error, _} = error ->

        {:reply, error, state}

    end

  end



  @impl true

  def handle_info({:tigerbeetlex_response, ref, response}, state) do

    {from, new_pending_requests} = Map.pop!(state.pending_requests, ref)

    response = Response.decode(response)

    GenServer.reply(from, response)

    {:noreply, %{state | pending_requests: new_pending_requests}}

  end

end