async def _dump_container_size(
            self, writer, container_len, container_type, params=None
    ):
        """
        Dumps container size - per element streaming
        :param writer:
        :param container_len:
        :param container_type:
        :param params:
        :return:
        """
        if not container_type or not container_type.FIX_SIZE:
            await dump_uvarint(writer, container_len)
        elif container_len != container_type.SIZE:
            raise ValueError(
                "Fixed size container has not defined size: %s" % container_type.SIZE
            )