@Test void removeAllShouldNotThrowWhenAbsent() { assertThatCode(() -> testee.removeAll(MAILBOX_ID).block()).doesNotThrowAnyException(); }
public Mono<Void> removeAll(CassandraId cassandraId) { return cassandraAsyncExecutor.executeVoid(deleteAllStatement.bind() .setUUID(MAILBOX_ID, cassandraId.asUuid())); }
CassandraFirstUnseenDAO { public Mono<Void> removeAll(CassandraId cassandraId) { return cassandraAsyncExecutor.executeVoid(deleteAllStatement.bind() .setUUID(MAILBOX_ID, cassandraId.asUuid())); } }
CassandraFirstUnseenDAO { public Mono<Void> removeAll(CassandraId cassandraId) { return cassandraAsyncExecutor.executeVoid(deleteAllStatement.bind() .setUUID(MAILBOX_ID, cassandraId.asUuid())); } @Inject  CassandraFirstUnseenDAO(Session session); }
CassandraFirstUnseenDAO { public Mono<Void> removeAll(CassandraId cassandraId) { return cassandraAsyncExecutor.executeVoid(deleteAllStatement.bind() .setUUID(MAILBOX_ID, cassandraId.asUuid())); } @Inject  CassandraFirstUnseenDAO(Session session); Mono<Void> addUnread(CassandraId cassandraId, MessageUid uid); Mono<Void> removeUnread(CassandraId cassandraId, MessageUid uid); Mono<Void> removeAll(CassandraId cassandraId); Mono<MessageUid> retrieveFirstUnread(CassandraId cassandraId); }
CassandraFirstUnseenDAO { public Mono<Void> removeAll(CassandraId cassandraId) { return cassandraAsyncExecutor.executeVoid(deleteAllStatement.bind() .setUUID(MAILBOX_ID, cassandraId.asUuid())); } @Inject  CassandraFirstUnseenDAO(Session session); Mono<Void> addUnread(CassandraId cassandraId, MessageUid uid); Mono<Void> removeUnread(CassandraId cassandraId, MessageUid uid); Mono<Void> removeAll(CassandraId cassandraId); Mono<MessageUid> retrieveFirstUnread(CassandraId cassandraId);  }