#vulnerable code 
                                public static Database create(int maxSize, boolean big, Scheduler scheduler) {
        return Database.from(Pools.nonBlocking() //
                .connectionProvider(connectionProvider(nextUrl(), big)) //
                .maxPoolSize(maxSize) //
                .scheduler(scheduler) //
                .build(), () -> scheduler.shutdown());
    } 
                            #location 2 
                            #vulnerability type RESOURCE_LEAK
#fixed code
                                public static Database create(int maxSize, boolean big, Scheduler scheduler) {
        NonBlockingConnectionPool pool = Pools.nonBlocking() //
                .connectionProvider(connectionProvider(nextUrl(), big)) //
                .maxPoolSize(maxSize) //
                .scheduler(scheduler) //
                .build();
        return Database.from(pool, () -> {
                    pool.close();
                    scheduler.shutdown();
                });
    }