Committed by
Gerrit Code Review
Attempt to fix sporadic NettyMessagingManagerTest failure.
Change-Id: Iae570c329a3fe0e7e46f9caf13a5b283a2153ed4
Showing
1 changed file
with
1 additions
and
1 deletions
... | @@ -280,7 +280,7 @@ public class NettyMessagingManager implements MessagingService { | ... | @@ -280,7 +280,7 @@ public class NettyMessagingManager implements MessagingService { |
280 | if (e != null) { | 280 | if (e != null) { |
281 | callbacks.invalidate(messageId); | 281 | callbacks.invalidate(messageId); |
282 | } | 282 | } |
283 | - }).thenCompose(v -> response); | 283 | + }).thenComposeAsync(v -> response, executor); |
284 | } | 284 | } |
285 | 285 | ||
286 | @Override | 286 | @Override | ... | ... |
-
Please register or login to post a comment