Merge pull request #1 from ertgl/replication_imp

Make Replicator.GenServer returns node names with results.

README.md

@@ -48,17 +48,19 @@ defmodule Storage.KV do
 	end
 
 	def set(key, value) do
-		Distributed.Replicator.GenServer.cast(__MODULE__.process_id(), {:set, key, value})
-		|> List.first()
+		{_node_name, result} = Distributed.Replicator.GenServer.cast(__MODULE__.process_id(), {:set, key, value})
+			|> List.first()
+		result
 	end
 
 	def has?(key) do
 		Distributed.Scaler.GenServer.call(__MODULE__.process_id(), {:has, key})
 	end
 
 	def pop(key, default \\ nil) do
-		Distributed.Replicator.GenServer.call(__MODULE__.process_id(), {:pop, key, default})
-		|> List.first()
+		{_node_name, result} = Distributed.Replicator.GenServer.call(__MODULE__.process_id(), {:pop, key, default})
+			|> List.first()
+		result
 	end
 
 end

lib/distributed/replicator/gen_server.ex

@@ -30,7 +30,9 @@ defmodule Distributed.Replicator.GenServer do
 	"""
 	@spec info(dest :: pid | port | atom, msg :: any, opts :: [any]) :: any
 	def info(dest, msg, opts \\ []) do
-		Distributed.Parallel.map(Distributed.Node.list(opts), &(send({dest, &1}, msg)))
+		Distributed.Parallel.map(Distributed.Node.list(opts), fn node_name ->
+			{node_name, send({dest, node_name}, msg)}
+		end)
 	end
 
 	@doc """
@@ -39,15 +41,19 @@ defmodule Distributed.Replicator.GenServer do
 	@spec call(server :: atom, term, opts :: [any]) :: [term]
 	def call(server, term, opts \\ []) do
 		timeout = Keyword.get(opts, :timeout, :infinity)
-		Distributed.Parallel.map(Distributed.Node.list(opts), &(GenServer.call({server, &1}, term, timeout)))
+		Distributed.Parallel.map(Distributed.Node.list(opts), fn node_name ->
+			{node_name, GenServer.call({server, node_name}, term, timeout)}
+		end)
 	end
 
 	@doc """
 	Sends asynchronous requests to the servers on nodes. See `GenServer.cast/2`
 	"""
 	@spec cast(server :: atom, term :: term, opts :: [any]) :: [term]
 	def cast(server, term, opts \\ []) do
-		Distributed.Parallel.map(Distributed.Node.list(opts), &(GenServer.cast({server, &1}, term)))
+		Distributed.Parallel.map(Distributed.Node.list(opts), fn node_name ->
+			{node_name, GenServer.cast({server, node_name}, term)}
+		end)
 	end
 
 end

mix.exs

@@ -9,7 +9,7 @@ defmodule Distributed.Mixfile do
 			description: description(),
 			package: package(),
 			app: :distributed,
-			version: "0.1.0",
+			version: "0.1.2",
 			elixir: "~> 1.4",
 			build_embedded: Mix.env() == :prod,
 			start_permanent: Mix.env() == :prod,