We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d664306 commit b0cd328Copy full SHA for b0cd328
topic/src/main/java/tech/ydb/topic/write/impl/WriterImpl.java
@@ -269,6 +269,11 @@ protected CompletableFuture<CompletableFuture<WriteAck>> sendImpl(Message messag
269
return tryToEnqueue(enqueuedMessage, instant).thenApply(v -> enqueuedMessage.getFuture());
270
}
271
272
+ /**
273
+ * Create a wrapper upon the future for the flush method.
274
+ *
275
+ * @return an empty Future if successful. Throw CompletionException when an error occurs.
276
+ */
277
protected CompletableFuture<Void> flushImpl() {
278
if (this.lastAcceptedMessageFuture == null) {
279
return CompletableFuture.completedFuture(null);
0 commit comments