@Test void countAllShouldReturnZeroByDefault() { assertThat(testee.countAll().block()) .isEqualTo(0); }
public Mono<Long> countAll() { return cassandraAsyncExecutor.executeSingleRowOptional(countAll.bind()) .map(optional -> optional.map(row -> row.getLong(FIRST_CELL)).orElse(0L)); }
CassandraMailboxPathDAOImpl { public Mono<Long> countAll() { return cassandraAsyncExecutor.executeSingleRowOptional(countAll.bind()) .map(optional -> optional.map(row -> row.getLong(FIRST_CELL)).orElse(0L)); } }
CassandraMailboxPathDAOImpl { public Mono<Long> countAll() { return cassandraAsyncExecutor.executeSingleRowOptional(countAll.bind()) .map(optional -> optional.map(row -> row.getLong(FIRST_CELL)).orElse(0L)); } @Inject  CassandraMailboxPathDAOImpl(Session session, CassandraTypesProvider typesProvider,
                                       CassandraUtils cassandraUtils,
                                       CassandraConsistenciesConfiguration consistenciesConfiguration); @VisibleForTesting  CassandraMailboxPathDAOImpl(Session session, CassandraTypesProvider typesProvider,
                                       CassandraConsistenciesConfiguration consistenciesConfiguration); }
CassandraMailboxPathDAOImpl { public Mono<Long> countAll() { return cassandraAsyncExecutor.executeSingleRowOptional(countAll.bind()) .map(optional -> optional.map(row -> row.getLong(FIRST_CELL)).orElse(0L)); } @Inject  CassandraMailboxPathDAOImpl(Session session, CassandraTypesProvider typesProvider,
                                       CassandraUtils cassandraUtils,
                                       CassandraConsistenciesConfiguration consistenciesConfiguration); @VisibleForTesting  CassandraMailboxPathDAOImpl(Session session, CassandraTypesProvider typesProvider,
                                       CassandraConsistenciesConfiguration consistenciesConfiguration); Mono<CassandraIdAndPath> retrieveId(MailboxPath mailboxPath); Flux<CassandraIdAndPath> listUserMailboxes(String namespace, Username user); void logGhostMailboxSuccess(CassandraIdAndPath value); void logGhostMailboxFailure(MailboxPath mailboxPath); @VisibleForTesting Mono<Boolean> save(MailboxPath mailboxPath, CassandraId mailboxId); Mono<Void> delete(MailboxPath mailboxPath); Flux<CassandraIdAndPath> readAll(); Mono<Long> countAll(); }
CassandraMailboxPathDAOImpl { public Mono<Long> countAll() { return cassandraAsyncExecutor.executeSingleRowOptional(countAll.bind()) .map(optional -> optional.map(row -> row.getLong(FIRST_CELL)).orElse(0L)); } @Inject  CassandraMailboxPathDAOImpl(Session session, CassandraTypesProvider typesProvider,
                                       CassandraUtils cassandraUtils,
                                       CassandraConsistenciesConfiguration consistenciesConfiguration); @VisibleForTesting  CassandraMailboxPathDAOImpl(Session session, CassandraTypesProvider typesProvider,
                                       CassandraConsistenciesConfiguration consistenciesConfiguration); Mono<CassandraIdAndPath> retrieveId(MailboxPath mailboxPath); Flux<CassandraIdAndPath> listUserMailboxes(String namespace, Username user); void logGhostMailboxSuccess(CassandraIdAndPath value); void logGhostMailboxFailure(MailboxPath mailboxPath); @VisibleForTesting Mono<Boolean> save(MailboxPath mailboxPath, CassandraId mailboxId); Mono<Void> delete(MailboxPath mailboxPath); Flux<CassandraIdAndPath> readAll(); Mono<Long> countAll();  }