diff options
author | Michael Schaefermeyer <michael.schaefermeyer@gmail.com> | 2016-09-02 10:57:38 +0200 |
---|---|---|
committer | Michael Schaefermeyer <michael.schaefermeyer@gmail.com> | 2016-09-02 10:57:41 +0200 |
commit | 5654e5f14dd42fb36268995323dc526d335d00a9 (patch) | |
tree | 3e05012fc36e9d425b6157779db5067d089f315e /lib/boltex/bolt.ex | |
parent | 01d2c03837b964da81a0195e7b0c6a7257e49756 (diff) | |
download | boltex-5654e5f14dd42fb36268995323dc526d335d00a9.tar.gz boltex-5654e5f14dd42fb36268995323dc526d335d00a9.tar.xz |
Refactor following credo
Diffstat (limited to 'lib/boltex/bolt.ex')
-rw-r--r-- | lib/boltex/bolt.ex | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/lib/boltex/bolt.ex b/lib/boltex/bolt.ex index 984d0b6..d433ea6 100644 --- a/lib/boltex/bolt.ex +++ b/lib/boltex/bolt.ex @@ -89,7 +89,8 @@ defmodule Boltex.Bolt do Messages have to be in the form of {[messages], signature}. """ def send_messages(transport, port, messages) do - Enum.map(messages, &generate_binary_message/1) + messages + |> Enum.map(&generate_binary_message/1) |> generate_chunks |> Enum.each(&(transport.send(port, &1))) end @@ -151,7 +152,7 @@ defmodule Boltex.Bolt do ] with {:success, %{}} = data <- receive_data(transport, port), - do: [data | receive_data(transport, port) |> List.wrap] + do: [data | transport |> receive_data(port) |> List.wrap] end @doc """ @@ -178,7 +179,7 @@ defmodule Boltex.Bolt do * `:failure` """ def receive_data(transport, port, previous \\ []) do - case do_receive_data(transport, port) |> unpack do + case transport |> do_receive_data(transport) |> unpack do {:record, _} = data -> receive_data transport, port, [data | previous] @@ -207,7 +208,6 @@ defmodule Boltex.Bolt do {:error, :timeout} -> {:error, :no_more_data_received} other -> - IO.inspect Utils.hex_encode other raise "receive failed" end end |