@Test void readAllShouldReturnEmptyByDefault() { assertThat(testee.readAll().toIterable()) .isEmpty(); }
public Flux<CassandraIdAndPath> readAll() { return cassandraAsyncExecutor.executeRows(selectAll.bind()) .map(this::fromRowToCassandraIdAndPath); }
CassandraMailboxPathDAOImpl { public Flux<CassandraIdAndPath> readAll() { return cassandraAsyncExecutor.executeRows(selectAll.bind()) .map(this::fromRowToCassandraIdAndPath); } }
CassandraMailboxPathDAOImpl { public Flux<CassandraIdAndPath> readAll() { return cassandraAsyncExecutor.executeRows(selectAll.bind()) .map(this::fromRowToCassandraIdAndPath); } @Inject  CassandraMailboxPathDAOImpl(Session session, CassandraTypesProvider typesProvider,
                                       CassandraUtils cassandraUtils,
                                       CassandraConsistenciesConfiguration consistenciesConfiguration); @VisibleForTesting  CassandraMailboxPathDAOImpl(Session session, CassandraTypesProvider typesProvider,
                                       CassandraConsistenciesConfiguration consistenciesConfiguration); }
CassandraMailboxPathDAOImpl { public Flux<CassandraIdAndPath> readAll() { return cassandraAsyncExecutor.executeRows(selectAll.bind()) .map(this::fromRowToCassandraIdAndPath); } @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 Flux<CassandraIdAndPath> readAll() { return cassandraAsyncExecutor.executeRows(selectAll.bind()) .map(this::fromRowToCassandraIdAndPath); } @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();  }