Cleanup compiler warnings around naked function calls.
MODIFY
lib/kafka_ex/server_0_p_8_p_0.ex
lib/kafka_ex/server_0_p_8_p_0.ex
@@ -24,7 +24,7 @@ defmodule KafkaEx.Server0P8P0 do
alias KafkaEx.NetworkClient
def kafka_server_init([args]) do
- kafka_server_init([args, self])
+ kafka_server_init([args, self()])
end
def kafka_server_init([args, name]) do
@@ -85,7 +85,7 @@ defmodule KafkaEx.Server0P8P0 do
end
ref = Process.send_after(
- self, {:start_streaming, %{fetch_request | offset: offset}}, 500
+ self(), {:start_streaming, %{fetch_request | offset: offset}}, 500
)
{:noreply, %{state | stream_timer: ref}}

MODIFY
lib/kafka_ex/server_0_p_8_p_2.ex
lib/kafka_ex/server_0_p_8_p_2.ex
@@ -34,7 +34,7 @@ defmodule KafkaEx.Server0P8P2 do
end
def kafka_server_init([args]) do
- kafka_server_init([args, self])
+ kafka_server_init([args, self()])
end
def kafka_server_init([args, name]) do
@@ -132,7 +132,7 @@ defmodule KafkaEx.Server0P8P2 do
end
ref = Process.send_after(
- self, {:start_streaming, %{fetch_request | offset: offset}}, 500
+ self(), {:start_streaming, %{fetch_request | offset: offset}}, 500
)
{:noreply, %{state | stream_timer: ref}}

MODIFY
lib/kafka_ex/server_0_p_9_p_0.ex
lib/kafka_ex/server_0_p_9_p_0.ex
@@ -30,7 +30,7 @@ defmodule KafkaEx.Server0P9P0 do
end
def kafka_server_init([args]) do
- kafka_server_init([args, self])
+ kafka_server_init([args, self()])
end
def kafka_server_init([args, name]) do
@@ -167,7 +167,7 @@ defmodule KafkaEx.Server0P9P0 do
end
ref = Process.send_after(
- self, {:start_streaming, %{fetch_request | offset: offset}}, 500
+ self(), {:start_streaming, %{fetch_request | offset: offset}}, 500
)
{:noreply, %{state | stream_timer: ref}}

MODIFY
mix.exs
mix.exs
@@ -12,9 +12,9 @@ defmodule KafkaEx.Mixfile do
"-Wrace_conditions",
]
],
- description: description,
- package: package,
- deps: deps,
+ description: description(),
+ package: package(),
+ deps: deps(),
docs: [main: "KafkaEx"]]
end

Cleanup compiler warnings around naked function calls.