@Test void getCountShouldReturnZeroWhenEmpty() { assertThat(testee.getCount(URL).block()) .isEqualTo(0L); }
public Mono<Long> getCount(MailRepositoryUrl url) { return executor.executeSingleRowOptional(select.bind() .setString(REPOSITORY_NAME, url.asString())) .map(this::toCount); }
CassandraMailRepositoryCountDAO { public Mono<Long> getCount(MailRepositoryUrl url) { return executor.executeSingleRowOptional(select.bind() .setString(REPOSITORY_NAME, url.asString())) .map(this::toCount); } }
CassandraMailRepositoryCountDAO { public Mono<Long> getCount(MailRepositoryUrl url) { return executor.executeSingleRowOptional(select.bind() .setString(REPOSITORY_NAME, url.asString())) .map(this::toCount); } @Inject  CassandraMailRepositoryCountDAO(Session session); }
CassandraMailRepositoryCountDAO { public Mono<Long> getCount(MailRepositoryUrl url) { return executor.executeSingleRowOptional(select.bind() .setString(REPOSITORY_NAME, url.asString())) .map(this::toCount); } @Inject  CassandraMailRepositoryCountDAO(Session session); Mono<Void> increment(MailRepositoryUrl url); Mono<Void> decrement(MailRepositoryUrl url); Mono<Long> getCount(MailRepositoryUrl url); }
CassandraMailRepositoryCountDAO { public Mono<Long> getCount(MailRepositoryUrl url) { return executor.executeSingleRowOptional(select.bind() .setString(REPOSITORY_NAME, url.asString())) .map(this::toCount); } @Inject  CassandraMailRepositoryCountDAO(Session session); Mono<Void> increment(MailRepositoryUrl url); Mono<Void> decrement(MailRepositoryUrl url); Mono<Long> getCount(MailRepositoryUrl url);  }