async def METHOD_NAME(self, *, stream, app):
    print("TEST AITER TRACKED")
    event = await self._assert_stream_aiter(
        stream,
        side_effect=None,
        raises=None,
    )
    if not event.ack.called:
        assert event.message.refcount == 0
        assert event.message.acked
    else:
        event.ack.assert_called_once_with()