diff --git a/modem/arq_session_irs.py b/modem/arq_session_irs.py
index 0cbed199..db89ea0f 100644
--- a/modem/arq_session_irs.py
+++ b/modem/arq_session_irs.py
@@ -89,7 +89,6 @@ class ARQSessionIRS(arq_session.ARQSession):
     def on_data_received(self, frame):
         if self.state != self.STATE_WAITING_DATA:
             raise RuntimeError(f"ARQ Session: Received data while in state {self.state}, expected {self.STATE_WAITING_DATA}")
-        self.rx_data_chain(frame)
         self.event_data_received.set()
 
     def on_transfer_ack_received(self, ack):
diff --git a/modem/frame_handler_arq_session.py b/modem/frame_handler_arq_session.py
index 5913b47e..34f95287 100644
--- a/modem/frame_handler_arq_session.py
+++ b/modem/frame_handler_arq_session.py
@@ -32,3 +32,4 @@ class ARQFrameHandler(frame_handler.FrameHandler):
             print("received data frame....")
             irs_session:ARQSessionIRS = self.states.get_arq_irs_session(frame['session_id'])
             irs_session.on_data_received(frame)
+            irs_session.rx_data_chain(frame)