

def _frame_loop(self, frame):
    if frame.heartbeat:
        self.last_received_frame = time.time()
    self.channels[frame.channel].process_frame(frame)
    self._frame_count += 1
    if self.stream:
        if (self._frame_count == 5):
            self._frame_count = 0
            cb = (lambda : FrameReader(self.stream, self._frame_loop))
            self._add_ioloop_callback(cb)
        else:
            FrameReader(self.stream, self._frame_loop)

dataset/ETHPy150Open paolo-losi/stormed-amqp/stormed/connection.py Connection._frame_loop/VarMisuse@13/16 `self`->`frame`