Skip to content

Commit

Permalink
fix: It helps if you call commit
Browse files Browse the repository at this point in the history
Signed-off-by: Ryan Roberts <ryan@blockchaintp.com>
  • Loading branch information
ryan-s-roberts committed Sep 24, 2021
1 parent fdeb31b commit d5eef32
Showing 1 changed file with 1 addition and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -119,6 +119,7 @@ public Future<Long> appendToLog(final Raw.LogEntryId key, final Raw.Envelope val
var work = sequenceAllocation.serialisedBegin(key)
.thenCompose(seq -> CompletableFuture.supplyAsync(() -> Functions.uncheckFn(() -> {
writer.sendEvent(key, value);
writer.commit(key);
return seq;
}).apply())).thenCompose(seq -> sequenceAllocation.serialisedCommit(seq));

Expand Down

0 comments on commit d5eef32

Please sign in to comment.