summaryrefslogtreecommitdiff
path: root/src/rabbit_net.erl
diff options
context:
space:
mode:
Diffstat (limited to 'src/rabbit_net.erl')
-rw-r--r--src/rabbit_net.erl14
1 files changed, 4 insertions, 10 deletions
diff --git a/src/rabbit_net.erl b/src/rabbit_net.erl
index 9604d79a..dfa00a6a 100644
--- a/src/rabbit_net.erl
+++ b/src/rabbit_net.erl
@@ -51,16 +51,10 @@ async_recv(Sock, Length, Timeout) when is_record(Sock, ssl_socket) ->
Ref = make_ref(),
- Fun = fun() ->
- case ssl:recv(Sock#ssl_socket.ssl, Length, Timeout) of
- {ok, Data} ->
- Pid ! {inet_async, Sock, Ref, {ok, Data}};
- {error, Reason} ->
- Pid ! {inet_async, Sock, Ref, {error, Reason}}
- end
- end,
-
- spawn(Fun),
+ spawn(fun() -> Pid ! {inet_async, Sock, Ref,
+ ssl:recv(Sock#ssl_socket.ssl, Length, Timeout)}
+ end),
+
{ok, Ref};
async_recv(Sock, Length, Timeout) when is_port(Sock) ->