Add missing decoration of Callable<V>

context-propagation/src/main/java/io/smallrye/mutiny/context/BaseContextPropagationInterceptor.java

@@ -1,5 +1,6 @@
 package io.smallrye.mutiny.context;
 
+import java.util.concurrent.Callable;
 import java.util.concurrent.Executor;
 import java.util.function.*;
 
@@ -68,6 +69,15 @@ public Runnable decorate(Runnable runnable) {
         return context.contextualRunnable(runnable);
     }
 
+    @Override
+    public <V> Callable<V> decorate(Callable<V> callable) {
+        SmallRyeThreadContext context = getThreadContext();
+        if (context.isContextualized(callable)) {
+            return callable;
+        }
+        return context.contextualCallable(callable);
+    }
+
     @Override
     public <T1, T2> BiConsumer<T1, T2> decorate(BiConsumer<T1, T2> consumer) {
         SmallRyeThreadContext context = getThreadContext();

implementation/src/main/java/io/smallrye/mutiny/infrastructure/CallbackDecorator.java

@@ -1,5 +1,6 @@
 package io.smallrye.mutiny.infrastructure;
 
+import java.util.concurrent.Callable;
 import java.util.function.*;
 
 import io.smallrye.mutiny.tuples.Functions;
@@ -8,7 +9,7 @@
  * Intercept user callbacks.
  * Decorators are called when the user passes a callback to Mutiny and so decorators can modify the passed callback.
  * <p>
- * The default behavior is to returns the user's callback, unchanged.
+ * The default behavior is to return the user's callback, unchanged.
  * <p>
  * Decorators must not transform a user callback into {@code null}.
  */
@@ -56,6 +57,17 @@ default Runnable decorate(Runnable runnable) {
         return runnable;
     }
 
+    /**
+     * Allows decorating a {@link Callable}.
+     *
+     * @param callable the callable
+     * @return the decorated callable
+     * @param <V> the callable return type
+     */
+    default <V> Callable<V> decorate(Callable<V> callable) {
+        return callable;
+    }
+
     /**
      * Allows decorating a {@link BiConsumer}.
      *

implementation/src/main/java/io/smallrye/mutiny/infrastructure/Infrastructure.java

@@ -153,6 +153,14 @@ public static Runnable decorate(Runnable runnable) {
         return current;
     }
 
+    public static <V> Callable<V> decorate(Callable<V> callable) {
+        Callable<V> current = callable;
+        for (CallbackDecorator interceptor : CALLBACK_DECORATORS) {
+            current = interceptor.decorate(current);
+        }
+        return current;
+    }
+
     public static <T1, T2> BiConsumer<T1, T2> decorate(BiConsumer<T1, T2> consumer) {
         BiConsumer<T1, T2> current = consumer;
         for (CallbackDecorator interceptor : CALLBACK_DECORATORS) {