Merge pull request #590 from indrekj/spec-fix

Fix type spec in brod_transaction
kafka4beam · Jul 2, 2024 · f8aec1a · f8aec1a
2 parents 636e448 + d253047
commit f8aec1a
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/src/brod_transaction.erl b/src/brod_transaction.erl
@@ -133,10 +133,10 @@
 %%==============================================================================
 
 %% @see start_link/3
--spec new(pid(), transactional_id(), transaction_config()) -> {ok, transaction()}.
-new(ClientPid, TxId, Config) ->
+-spec new(client(), transactional_id(), transaction_config()) -> {ok, transaction()}.
+new(Client, TxId, Config) ->
   gen_server:start_link(?MODULE,
-                        {ClientPid, TxId, Config},
+                        {Client, TxId, Config},
                         []).
 
 %% @doc Start a new transaction, `TxId'will be the id of the transaction
@@ -145,9 +145,9 @@ new(ClientPid, TxId, Config) ->
 %% `backoff_step': after each retry it will sleep for 2^Attempt * backoff_step
 %%  millis
 %% `max_retries'
--spec start_link(pid(), transactional_id(), transaction_config()) -> {ok, pid()}.
-start_link(ClientPid, TxId, Config) ->
-  gen_server:start_link(?MODULE, {ClientPid, TxId, Config}, []).
+-spec start_link(client(), transactional_id(), transaction_config()) -> {ok, pid()}.
+start_link(Client, TxId, Config) ->
+  gen_server:start_link(?MODULE, {Client, TxId, Config}, []).
 
 %% @doc Produce the message (key and value) to the indicated topic-partition
 %% synchronously.