CassandraUserMailboxRightsDAO { public Flux<Pair<CassandraId, Rfc4314Rights>> listRightsForUser(Username userName) { return cassandraAsyncExecutor.execute( selectUser.bind() .setString(USER_NAME, userName.asString())) .flatMapMany(cassandraUtils::convertToFlux) .map(Throwing.function(this::toPair)); } @Inject  CassandraUserMailboxRightsDAO(Session session, CassandraUtils cassandraUtils); Mono<Void> update(CassandraId cassandraId, ACLDiff aclDiff); Mono<Optional<Rfc4314Rights>> retrieve(Username userName, CassandraId mailboxId); Flux<Pair<CassandraId, Rfc4314Rights>> listRightsForUser(Username userName);  }
@Test void listRightsForUserShouldReturnEmptyWhenEmptyData() { assertThat(testee.listRightsForUser(USER_NAME).collectList().block()) .isEmpty(); }