diff options
-rw-r--r-- | lib/boltex/bolt.ex | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/boltex/bolt.ex b/lib/boltex/bolt.ex index 8bbf3e7..984d0b6 100644 --- a/lib/boltex/bolt.ex +++ b/lib/boltex/bolt.ex @@ -150,8 +150,8 @@ defmodule Boltex.Bolt do {[nil], @sig_pull_all} ] - with {:success, %{}} <- receive_data(transport, port), - do: receive_data transport, port + with {:success, %{}} = data <- receive_data(transport, port), + do: [data | receive_data(transport, port) |> List.wrap] end @doc """ |