@Test void listShouldBeEmptyByDefault() { assertThat(testee.list(URL).collectList().block()) .isEmpty(); }
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))); }
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))); } }
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  CassandraMailRepositoryKeysDAO(Session session, CassandraUtils cassandraUtils); }
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  CassandraMailRepositoryKeysDAO(Session session, CassandraUtils cassandraUtils); Mono<Boolean> store(MailRepositoryUrl url, MailKey key); Flux<MailKey> list(MailRepositoryUrl url); Mono<Boolean> remove(MailRepositoryUrl url, MailKey key); }
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  CassandraMailRepositoryKeysDAO(Session session, CassandraUtils cassandraUtils); Mono<Boolean> store(MailRepositoryUrl url, MailKey key); Flux<MailKey> list(MailRepositoryUrl url); Mono<Boolean> remove(MailRepositoryUrl url, MailKey key);  }