From db0fd8ecd6f03f198f7dbc0b6f4b5c65ac770363 Mon Sep 17 00:00:00 2001
From: Burmaja Milan <burmajam@gmail.com>
Date: Tue, 18 Jun 2024 16:45:22 +0100
Subject: [PATCH] rename private function names

---
 lib/kelvin/in_order_subscription.ex | 32 ++++++++++++++---------------
 1 file changed, 16 insertions(+), 16 deletions(-)

diff --git a/lib/kelvin/in_order_subscription.ex b/lib/kelvin/in_order_subscription.ex
index b0b499a..d90c6d3 100644
--- a/lib/kelvin/in_order_subscription.ex
+++ b/lib/kelvin/in_order_subscription.ex
@@ -75,7 +75,7 @@ defmodule Kelvin.InOrderSubscription do
   def handle_info(:check_auto_subscribe, state) do
     identifier = "#{inspect(__MODULE__)} (#{inspect(state.self)})"
 
-    if do_function(state.config.subscribe_on_init?) do
+    if _do_function(state.config.subscribe_on_init?) do
       Logger.info("#{identifier} subscribing to '#{state.config.stream_name}'")
 
       GenStage.async_info(self(), :subscribe)
@@ -97,7 +97,7 @@ defmodule Kelvin.InOrderSubscription do
       Logger.warn("#{inspect(__MODULE__)} is already subscribed.")
       # coveralls-ignore-stop
     else
-      case subscribe(state) do
+      case _subscribe(state) do
         {:ok, sub} ->
           Process.link(sub)
           {:noreply, [], put_in(state.subscription, sub)}
@@ -119,10 +119,10 @@ defmodule Kelvin.InOrderSubscription do
     case state do
       %{demand: 0, buffer_size: size, max_buffer_size: max}
       when size + 1 == max ->
-        {:noreply, [], enqueue(state, {event, from})}
+        {:noreply, [], _enqueue(state, {event, from})}
 
       %{demand: 0} ->
-        {:reply, :ok, [], enqueue(state, event)}
+        {:reply, :ok, [], _enqueue(state, event)}
 
       %{demand: demand} ->
         {:reply, :ok, [{state.self, event}], put_in(state.demand, demand - 1)}
@@ -131,26 +131,26 @@ defmodule Kelvin.InOrderSubscription do
 
   @impl GenStage
   def handle_demand(demand, state) do
-    dequeue_events(state, demand, [])
+    _dequeue_events(state, demand, [])
   end
 
-  defp dequeue_events(%{buffer_size: size} = state, demand, events)
+  defp _dequeue_events(%{buffer_size: size} = state, demand, events)
        when size == 0 or demand == 0 do
     {:noreply, :lists.reverse(events), put_in(state.demand, demand)}
   end
 
-  defp dequeue_events(state, demand, events) do
-    case dequeue(state) do
+  defp _dequeue_events(state, demand, events) do
+    case _dequeue(state) do
       {{:value, {event, from}}, state} ->
         GenStage.reply(from, :ok)
-        dequeue_events(state, demand - 1, [{state.self, event} | events])
+        _dequeue_events(state, demand - 1, [{state.self, event} | events])
 
       {{:value, event}, state} ->
-        dequeue_events(state, demand - 1, [{state.self, event} | events])
+        _dequeue_events(state, demand - 1, [{state.self, event} | events])
     end
   end
 
-  defp dequeue(state) do
+  defp _dequeue(state) do
     case :queue.out(state.buffer) do
       # coveralls-ignore-start
       {:empty, buffer} ->
@@ -162,25 +162,25 @@ defmodule Kelvin.InOrderSubscription do
     end
   end
 
-  defp subscribe(state) do
+  defp _subscribe(state) do
     state.config.connection
     |> Extreme.RequestManager._name()
     |> GenServer.call(
       {:read_and_stay_subscribed, self(),
        {state.config.stream_name,
-        do_function(state.config.restore_stream_position!) + 1,
+        _do_function(state.config.restore_stream_position!) + 1,
         state.max_buffer_size, true, false, :infinity}},
       :infinity
     )
   end
 
-  defp do_function(func) when is_function(func, 0), do: func.()
+  defp _do_function(func) when is_function(func, 0), do: func.()
 
-  defp do_function({m, f, a}) when is_atom(m) and is_atom(f) and is_list(a) do
+  defp _do_function({m, f, a}) when is_atom(m) and is_atom(f) and is_list(a) do
     apply(m, f, a)
   end
 
-  defp enqueue(state, element) do
+  defp _enqueue(state, element) do
     %{
       state
       | buffer: :queue.in(element, state.buffer),