@Test void retrieveDeletedMessageShouldReturnOneMessageForMessageRangeOneIfThisMessageIsPresent() { addMessageForRetrieveTest(); List<MessageUid> result = testee .retrieveDeletedMessage(MAILBOX_ID, MessageRange.one(UID_1)) .collectList() .block(); assertThat(result).containsExactly(UID_1); }
public Flux<MessageUid> retrieveDeletedMessage(CassandraId cassandraId, MessageRange range) { return retrieveResultSetOfDeletedMessage(cassandraId, range) .flatMapMany(this::resultSetToFlux); }
CassandraDeletedMessageDAO { public Flux<MessageUid> retrieveDeletedMessage(CassandraId cassandraId, MessageRange range) { return retrieveResultSetOfDeletedMessage(cassandraId, range) .flatMapMany(this::resultSetToFlux); } }
CassandraDeletedMessageDAO { public Flux<MessageUid> retrieveDeletedMessage(CassandraId cassandraId, MessageRange range) { return retrieveResultSetOfDeletedMessage(cassandraId, range) .flatMapMany(this::resultSetToFlux); } @Inject  CassandraDeletedMessageDAO(Session session, CassandraUtils cassandraUtils); @VisibleForTesting  CassandraDeletedMessageDAO(Session session); }
CassandraDeletedMessageDAO { public Flux<MessageUid> retrieveDeletedMessage(CassandraId cassandraId, MessageRange range) { return retrieveResultSetOfDeletedMessage(cassandraId, range) .flatMapMany(this::resultSetToFlux); } @Inject  CassandraDeletedMessageDAO(Session session, CassandraUtils cassandraUtils); @VisibleForTesting  CassandraDeletedMessageDAO(Session session); Mono<Void> addDeleted(CassandraId cassandraId, MessageUid uid); Mono<Void> removeDeleted(CassandraId cassandraId, MessageUid uid); Mono<Void> removeAll(CassandraId cassandraId); Flux<MessageUid> retrieveDeletedMessage(CassandraId cassandraId, MessageRange range); }
CassandraDeletedMessageDAO { public Flux<MessageUid> retrieveDeletedMessage(CassandraId cassandraId, MessageRange range) { return retrieveResultSetOfDeletedMessage(cassandraId, range) .flatMapMany(this::resultSetToFlux); } @Inject  CassandraDeletedMessageDAO(Session session, CassandraUtils cassandraUtils); @VisibleForTesting  CassandraDeletedMessageDAO(Session session); Mono<Void> addDeleted(CassandraId cassandraId, MessageUid uid); Mono<Void> removeDeleted(CassandraId cassandraId, MessageUid uid); Mono<Void> removeAll(CassandraId cassandraId); Flux<MessageUid> retrieveDeletedMessage(CassandraId cassandraId, MessageRange range);  }