aboutsummaryrefslogtreecommitdiff
path: root/lib/boltex/bolt.ex
diff options
context:
space:
mode:
Diffstat (limited to 'lib/boltex/bolt.ex')
-rw-r--r--lib/boltex/bolt.ex4
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 """