reader: fix cleanup decrementing
reader: guarantee cleanup of in flight messages