CassandraApplicableFlagDAO { public Mono<Flags> retrieveApplicableFlag(CassandraId mailboxId) { return cassandraAsyncExecutor.executeSingleRow( select.bind() .setUUID(MAILBOX_ID, mailboxId.asUuid())) .map(row -> new FlagsExtractor(row).getApplicableFlags()); } @Inject  CassandraApplicableFlagDAO(Session session); Mono<Void> delete(CassandraId mailboxId); Mono<Flags> retrieveApplicableFlag(CassandraId mailboxId); Mono<Void> updateApplicableFlags(CassandraId cassandraId, Set<String> toBeAdded);  }
@Test void updateApplicableFlagsShouldReturnEmptyByDefault() { assertThat(testee.retrieveApplicableFlag(CASSANDRA_ID).hasElement().block()) .isFalse(); }