diff options
| -rw-r--r-- | lib/boltex/bolt.ex | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/lib/boltex/bolt.ex b/lib/boltex/bolt.ex index 5c58a62..370d8b4 100644 --- a/lib/boltex/bolt.ex +++ b/lib/boltex/bolt.ex @@ -179,7 +179,7 @@ defmodule Boltex.Bolt do * `:failure` """ def receive_data(transport, port, previous \\ []) do - case transport |> do_receive_data(transport) |> unpack do + case transport |> do_receive_data(port) |> unpack do {:record, _} = data -> receive_data transport, port, [data | previous] |