send notification back when received DATA frame

It’s a very simple implement. Check other issues: joedevivo#57 joedevivo#73
tony612 · Oct 1, 2016 · 98d2d07 · 98d2d07
1 parent d59b541
commit 98d2d07
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/src/h2_connection.erl b/src/h2_connection.erl
@@ -1582,5 +1582,15 @@ recv_data(Stream, Frame) ->
             %% anyway.
             ok;
         Pid ->
+            NotifyPid = h2_stream_set:notify_pid(Stream),
+            recv_data_cb(NotifyPid, Frame),
             gen_fsm:send_event(Pid, {recv_data, Frame})
     end.
+
+recv_data_cb(Pid, {#frame_header{
+                  flags=Flags,
+                  type=?DATA
+                 }, Payload}) ->
+    Bin = h2_frame_data:data(Payload),
+    Pid ! {'RECV_DATA', Bin};
+recv_data_cb(_, _) -> ok.