Decode data before passing to callback

krestenkrab · Jun 17, 2011 · d7a24b9 · d7a24b9
1 parent 126317b
commit d7a24b9
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/stream_client.erl b/src/stream_client.erl
@@ -23,7 +23,10 @@ handle_connection(Callback, RequestId) ->
             handle_connection(Callback, RequestId);
 
         {http, {RequestId, stream, Data}} ->
-            _CallbackPid = spawn(fun() -> Callback(Data) end),
+            spawn(fun() ->
+                DecodedData = stream_client_util:decode(Data),
+                Callback(DecodedData)
+            end),
             handle_connection(Callback, RequestId);
 
         {http, {RequestId, stream_end, _Headers}} ->