class CassandraMailboxPathV2DAO {

    public Flux<CassandraIdAndPath> listAll() {
        return cassandraAsyncExecutor.execute(
            selectAll.bind())
            .flatMapMany(cassandraUtils::convertToFlux)
            .map(this::fromRowToCassandraIdAndPath)
            .map(FunctionalUtils.toFunction(this::logReadSuccess));
    }

    @Inject public  CassandraMailboxPathV2DAO(Session session, CassandraUtils cassandraUtils,
                                     CassandraConsistenciesConfiguration consistenciesConfiguration);

}