@Test void countUnseenMessagesInMailboxShouldReturnEmptyByDefault() { assertThat(testee.countUnseenMessagesInMailbox(mailbox).hasElement().block()).isFalse(); }
public Mono<Long> countUnseenMessagesInMailbox(Mailbox mailbox) { CassandraId mailboxId = (CassandraId) mailbox.getMailboxId(); return cassandraAsyncExecutor.executeSingleRow(bindWithMailbox(mailboxId, readStatement)) .map(row -> row.getLong(UNSEEN)); }
CassandraMailboxCounterDAO { public Mono<Long> countUnseenMessagesInMailbox(Mailbox mailbox) { CassandraId mailboxId = (CassandraId) mailbox.getMailboxId(); return cassandraAsyncExecutor.executeSingleRow(bindWithMailbox(mailboxId, readStatement)) .map(row -> row.getLong(UNSEEN)); } }
CassandraMailboxCounterDAO { public Mono<Long> countUnseenMessagesInMailbox(Mailbox mailbox) { CassandraId mailboxId = (CassandraId) mailbox.getMailboxId(); return cassandraAsyncExecutor.executeSingleRow(bindWithMailbox(mailboxId, readStatement)) .map(row -> row.getLong(UNSEEN)); } @Inject  CassandraMailboxCounterDAO(Session session); }
CassandraMailboxCounterDAO { public Mono<Long> countUnseenMessagesInMailbox(Mailbox mailbox) { CassandraId mailboxId = (CassandraId) mailbox.getMailboxId(); return cassandraAsyncExecutor.executeSingleRow(bindWithMailbox(mailboxId, readStatement)) .map(row -> row.getLong(UNSEEN)); } @Inject  CassandraMailboxCounterDAO(Session session); Mono<Void> delete(CassandraId mailboxId); Mono<MailboxCounters> retrieveMailboxCounters(CassandraId mailboxId); Mono<Void> resetCounters(MailboxCounters counters); Mono<Void> add(MailboxCounters counters); Mono<Void> remove(MailboxCounters counters); Mono<Long> countMessagesInMailbox(Mailbox mailbox); Mono<Long> countMessagesInMailbox(CassandraId cassandraId); Mono<Long> countUnseenMessagesInMailbox(Mailbox mailbox); Mono<Void> decrementCount(CassandraId mailboxId); Mono<Void> incrementCount(CassandraId mailboxId); Mono<Void> decrementUnseen(CassandraId mailboxId); Mono<Void> incrementUnseen(CassandraId mailboxId); Mono<Void> decrementUnseenAndCount(CassandraId mailboxId); Mono<Void> incrementUnseenAndCount(CassandraId mailboxId); }
CassandraMailboxCounterDAO { public Mono<Long> countUnseenMessagesInMailbox(Mailbox mailbox) { CassandraId mailboxId = (CassandraId) mailbox.getMailboxId(); return cassandraAsyncExecutor.executeSingleRow(bindWithMailbox(mailboxId, readStatement)) .map(row -> row.getLong(UNSEEN)); } @Inject  CassandraMailboxCounterDAO(Session session); Mono<Void> delete(CassandraId mailboxId); Mono<MailboxCounters> retrieveMailboxCounters(CassandraId mailboxId); Mono<Void> resetCounters(MailboxCounters counters); Mono<Void> add(MailboxCounters counters); Mono<Void> remove(MailboxCounters counters); Mono<Long> countMessagesInMailbox(Mailbox mailbox); Mono<Long> countMessagesInMailbox(CassandraId cassandraId); Mono<Long> countUnseenMessagesInMailbox(Mailbox mailbox); Mono<Void> decrementCount(CassandraId mailboxId); Mono<Void> incrementCount(CassandraId mailboxId); Mono<Void> decrementUnseen(CassandraId mailboxId); Mono<Void> incrementUnseen(CassandraId mailboxId); Mono<Void> decrementUnseenAndCount(CassandraId mailboxId); Mono<Void> incrementUnseenAndCount(CassandraId mailboxId);  }