This is an automated email from the ASF dual-hosted git repository.
dcapwell pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/cassandra-accord.git
The following commit(s) were added to refs/heads/trunk by this push:
new b37c43e (Accord) AsyncChain.flatMap does not begin the result of the
flatMap, which causes AsyncLoader to hang in some cases (#81)
b37c43e is described below
commit b37c43e5148228b309166d71080b5125faae85cc
Author: dcapwell <dcapw...@apache.org>
AuthorDate: Mon Feb 19 14:36:04 2024 -0800
(Accord) AsyncChain.flatMap does not begin the result of the flatMap, which
causes AsyncLoader to hang in some cases (#81)
patch by David Capwell; reviewed by Benedict Elliott Smith, David Capwell
for CASSANDRA-19405
---
accord-core/src/main/java/accord/utils/async/AsyncChains.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/accord-core/src/main/java/accord/utils/async/AsyncChains.java
b/accord-core/src/main/java/accord/utils/async/AsyncChains.java
index fcc2956..579bbf9 100644
--- a/accord-core/src/main/java/accord/utils/async/AsyncChains.java
+++ b/accord-core/src/main/java/accord/utils/async/AsyncChains.java
@@ -570,7 +570,7 @@ public abstract class AsyncChains<V> implements
AsyncChain<V>
executor.execute(() -> {
try
{
- mapper.apply(v).addCallback(callback);
+ mapper.apply(v).begin(callback);
}
catch (Throwable t)
{
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org
For additional commands, e-mail: commits-h...@cassandra.apache.org
