Skip to content

Instantly share code, notes, and snippets.

@blackheaven

blackheaven/CassandraModSeqProvider.java

Created January 29, 2019 14:41
Show Gist options
  • Save blackheaven/670d926d18d3ad8678c7e787ea9a519a to your computer and use it in GitHub Desktop.
Save blackheaven/670d926d18d3ad8678c7e787ea9a519a to your computer and use it in GitHub Desktop.
Download ZIP
Mono.defer allow to be replayable
Raw
CassandraModSeqProvider.java
private Mono<ModSeq> handleRetries(CassandraId mailboxId) {
return Mono.defer(() -> tryFindThenUpdateOnce(mailboxId))
.retry(maxModSeqRetries);
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment