diff options
| author | Michael Schaefermeyer <michael.schaefermeyer@gmail.com> | 2016-09-02 23:01:40 +0200 |
|---|---|---|
| committer | Michael Schaefermeyer <michael.schaefermeyer@gmail.com> | 2016-09-02 23:01:40 +0200 |
| commit | bb3484f98530a493f83686f639f39ac641aff7bf (patch) | |
| tree | fb81d417fed3e0471c0b6cc33b3f2400c01d7b01 | |
| parent | 9b9958f4427be9485b222f319fc9affbeecc53fa (diff) | |
| download | boltex-bb3484f98530a493f83686f639f39ac641aff7bf.tar.gz boltex-bb3484f98530a493f83686f639f39ac641aff7bf.tar.xz | |
Fix bug
| -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] |