diff options
| author | Michael Schaefermeyer <michael.schaefermeyer@gmail.com> | 2016-08-01 13:21:55 +0200 |
|---|---|---|
| committer | Michael Schaefermeyer <michael.schaefermeyer@gmail.com> | 2016-08-01 13:22:02 +0200 |
| commit | 5f20589ec75f582eaf9ca25741bad50d37447009 (patch) | |
| tree | e54f2b2d9511164255e617004111527f8c4a63fc | |
| parent | 5b2a832a42eece9cd13c43899298551ee4906878 (diff) | |
| download | boltex-5f20589ec75f582eaf9ca25741bad50d37447009.tar.gz boltex-5f20589ec75f582eaf9ca25741bad50d37447009.tar.xz | |
Add success to run_statement
Closes #1
| -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 """ |