CassandraDeletedMessageDAO { public Mono<Void> removeAll(CassandraId cassandraId) { return cassandraAsyncExecutor.executeVoid(deleteAllStatement.bind() .setUUID(MAILBOX_ID, cassandraId.asUuid())); } @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);  }
@Test void removeAllShouldNotThrowWhenEmpty() { assertThatCode(() -> testee.removeAll(MAILBOX_ID).block()).doesNotThrowAnyException(); }