async def METHOD_NAME(self, start):
    loop = asyncio.get_event_loop()
    interval = self._stats_interval
    i = 1
    try:
        while True:
            await asyncio.sleep(
                (start + i * interval) - loop.time())
            stats = self._stats[-1]
            self._stats.append(Counter())
            i += 1
            print(
                "Consumed {stats[count]} messages in {interval} second(s)."
                .format(stats=stats, interval=interval)
            )
    except asyncio.CancelledError:
        stats = sum(self._stats, Counter())
        total_time = loop.time() - start
        print(
            "Total consumed {stats[count]} messages in "
            "{time:.2f} second(s). Avg {avg} m/s.".format(
                stats=stats,
                time=total_time,
                avg=stats['count'] // total_time
            )
        )