From bb3484f98530a493f83686f639f39ac641aff7bf Mon Sep 17 00:00:00 2001 From: Michael Schaefermeyer Date: Fri, 2 Sep 2016 23:01:40 +0200 Subject: Fix bug --- lib/boltex/bolt.ex | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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] -- cgit v1.2.1