@Test void listAllShouldBeEmptyByDefault() { assertThat(testee.listAll().collectList().block()).isEmpty(); }
public Flux<CassandraIdAndPath> listAll() { return cassandraAsyncExecutor.execute( selectAll.bind()) .flatMapMany(cassandraUtils::convertToFlux) .map(this::fromRowToCassandraIdAndPath) .map(FunctionalUtils.toFunction(this::logReadSuccess)); }
CassandraMailboxPathV2DAO { public Flux<CassandraIdAndPath> listAll() { return cassandraAsyncExecutor.execute( selectAll.bind()) .flatMapMany(cassandraUtils::convertToFlux) .map(this::fromRowToCassandraIdAndPath) .map(FunctionalUtils.toFunction(this::logReadSuccess)); } }
CassandraMailboxPathV2DAO { public Flux<CassandraIdAndPath> listAll() { return cassandraAsyncExecutor.execute( selectAll.bind()) .flatMapMany(cassandraUtils::convertToFlux) .map(this::fromRowToCassandraIdAndPath) .map(FunctionalUtils.toFunction(this::logReadSuccess)); } @Inject  CassandraMailboxPathV2DAO(Session session, CassandraUtils cassandraUtils,
                                     CassandraConsistenciesConfiguration consistenciesConfiguration); }
CassandraMailboxPathV2DAO { public Flux<CassandraIdAndPath> listAll() { return cassandraAsyncExecutor.execute( selectAll.bind()) .flatMapMany(cassandraUtils::convertToFlux) .map(this::fromRowToCassandraIdAndPath) .map(FunctionalUtils.toFunction(this::logReadSuccess)); } @Inject  CassandraMailboxPathV2DAO(Session session, CassandraUtils cassandraUtils,
                                     CassandraConsistenciesConfiguration consistenciesConfiguration); Mono<CassandraIdAndPath> retrieveId(MailboxPath mailboxPath); Flux<CassandraIdAndPath> listUserMailboxes(String namespace, Username user); Flux<CassandraIdAndPath> listAll(); void logGhostMailboxSuccess(CassandraIdAndPath value); void logGhostMailboxFailure(MailboxPath mailboxPath); Mono<Boolean> save(MailboxPath mailboxPath, CassandraId mailboxId); Mono<Void> delete(MailboxPath mailboxPath); }
CassandraMailboxPathV2DAO { public Flux<CassandraIdAndPath> listAll() { return cassandraAsyncExecutor.execute( selectAll.bind()) .flatMapMany(cassandraUtils::convertToFlux) .map(this::fromRowToCassandraIdAndPath) .map(FunctionalUtils.toFunction(this::logReadSuccess)); } @Inject  CassandraMailboxPathV2DAO(Session session, CassandraUtils cassandraUtils,
                                     CassandraConsistenciesConfiguration consistenciesConfiguration); Mono<CassandraIdAndPath> retrieveId(MailboxPath mailboxPath); Flux<CassandraIdAndPath> listUserMailboxes(String namespace, Username user); Flux<CassandraIdAndPath> listAll(); void logGhostMailboxSuccess(CassandraIdAndPath value); void logGhostMailboxFailure(MailboxPath mailboxPath); Mono<Boolean> save(MailboxPath mailboxPath, CassandraId mailboxId); Mono<Void> delete(MailboxPath mailboxPath);  }