@GET
    @Path("updates")
    public Uni<Collection<World>> updates(@QueryParam("queries") String queries) {
        return worldRepository.inSession(session -> {
            // FIXME: not supported
            //          session.setJdbcBatchSize(worlds.size());
            session.setFlushMode(FlushMode.MANUAL);
            var worlds = randomWorldForRead(session, parseQueryCount(queries));
            return worlds.flatMap(worldsCollection -> {
                worldsCollection.forEach( w -> {
                    //Read the one field, as required by the following rule:
                    // # vi. At least the randomNumber field must be read from the database result set.
                    final int previousRead = w.getRandomNumber();
                    //Update it, but make sure to exclude the current number as Hibernate optimisations would have us "fail"
                    //the verification:
                    w.setRandomNumber(randomWorldNumber(previousRead));
                } );
                return worldRepository.update(session, worldsCollection);
            });
        });
    }
@GET
    @Path("updates")
    public Uni<Collection<World>> updates(@QueryParam("queries") String queries) {
        return worldRepository.inSession(session -> {
           
           
            session.setFlushMode(FlushMode.MANUAL);
            var worlds = randomWorldForRead(session, parseQueryCount(queries));
            return worlds.flatMap(worldsCollection -> {
                worldsCollection.forEach( w -> {
                   
                   
                    final int previousRead = w.getRandomNumber();
                   
                   
                    w.setRandomNumber(randomWorldNumber(previousRead));
                } );
                return worldRepository.update(session, worldsCollection);
            });
        });
    }
@get @path("updates") public uni<collection<world>> updates(@queryparam("queries") string queries) { return worldrepository.insession(session -> { session.setflushmode(flushmode.manual); var worlds = randomworldforread(session, parsequerycount(queries)); return worlds.flatmap(worldscollection -> { worldscollection.foreach( w -> { final int previousread = w.getrandomnumber(); w.setrandomnumber(randomworldnumber(previousread)); } ); return worldrepository.update(session, worldscollection); }); }); }