Rewrite rabbit_net:async_recv according to Matt's suggestion.

Interesting way of shortening the entire story. I like it...!

1 files changed, 4 insertions, 10 deletions

diff --git a/src/rabbit_net.erl b/src/rabbit_net.erl
index 9604d79a13..dfa00a6a33 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) ->