class CassandraMailRepositoryKeysDAO {

    public Flux<MailKey> list(MailRepositoryUrl url) {
        return executor.execute(listKeys.bind()
            .setString(REPOSITORY_NAME, url.asString()))
            .flatMapMany(cassandraUtils::convertToFlux)
            .map(row -> new MailKey(row.getString(MAIL_KEY)));
    }

    @Inject public  CassandraMailRepositoryKeysDAO(Session session, CassandraUtils cassandraUtils);

}