From ccc1ec9200d123c331fa0e8e3a6963aded42f7b0 Mon Sep 17 00:00:00 2001
From: Clement Escoffier <clement.escoffier@gmail.com>
Date: Wed, 27 May 2020 09:32:58 +0200
Subject: [PATCH 1/2] Update mutiny version to 0.5.2

---
 bom/runtime/pom.xml               | 2 +-
 independent-projects/qute/pom.xml | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/bom/runtime/pom.xml b/bom/runtime/pom.xml
index c60b23e869191..3114d3017edbb 100644
--- a/bom/runtime/pom.xml
+++ b/bom/runtime/pom.xml
@@ -126,7 +126,7 @@
         <netty.version>4.1.49.Final</netty.version>
         <reactive-streams.version>1.0.3</reactive-streams.version>
         <jboss-logging.version>3.3.2.Final</jboss-logging.version>
-        <mutiny.version>0.5.0</mutiny.version>
+        <mutiny.version>0.5.2</mutiny.version>
         <axle-client.version>0.0.16</axle-client.version>
         <mutiny-client.version>0.0.16</mutiny-client.version>
         <kafka2.version>2.5.0</kafka2.version>
diff --git a/independent-projects/qute/pom.xml b/independent-projects/qute/pom.xml
index 94e938d42cab0..68edfc417eebf 100644
--- a/independent-projects/qute/pom.xml
+++ b/independent-projects/qute/pom.xml
@@ -39,7 +39,7 @@
         <version.gizmo>1.0.3.Final</version.gizmo>
         <version.jboss-logging>3.3.2.Final</version.jboss-logging>
         <version.reactivestreams>1.0.3</version.reactivestreams>
-        <version.mutiny>0.5.0</version.mutiny>
+        <version.mutiny>0.5.2</version.mutiny>
         <version.nexus-staging-maven-plugin>1.6.8</version.nexus-staging-maven-plugin>
     </properties>
 

From 255f26467036bcdec0331cdc09ce31f5331973e0 Mon Sep 17 00:00:00 2001
From: Clement Escoffier <clement.escoffier@gmail.com>
Date: Tue, 26 May 2020 17:47:05 +0200
Subject: [PATCH 2/2] Configure Mutiny to use the Quarkus thread pool.

---
 .../quarkus/mutiny/deployment/MutinyProcessor.java | 13 +++++++++++++
 .../mutiny/runtime/MutinyInfrastructure.java       | 14 ++++++++++++++
 2 files changed, 27 insertions(+)
 create mode 100644 extensions/mutiny/runtime/src/main/java/io/quarkus/mutiny/runtime/MutinyInfrastructure.java

diff --git a/extensions/mutiny/deployment/src/main/java/io/quarkus/mutiny/deployment/MutinyProcessor.java b/extensions/mutiny/deployment/src/main/java/io/quarkus/mutiny/deployment/MutinyProcessor.java
index 9d0261e481c01..566082f631b7f 100644
--- a/extensions/mutiny/deployment/src/main/java/io/quarkus/mutiny/deployment/MutinyProcessor.java
+++ b/extensions/mutiny/deployment/src/main/java/io/quarkus/mutiny/deployment/MutinyProcessor.java
@@ -1,7 +1,13 @@
 package io.quarkus.mutiny.deployment;
 
+import java.util.concurrent.ExecutorService;
+
 import io.quarkus.deployment.annotations.BuildStep;
+import io.quarkus.deployment.annotations.ExecutionTime;
+import io.quarkus.deployment.annotations.Record;
+import io.quarkus.deployment.builditem.ExecutorBuildItem;
 import io.quarkus.deployment.builditem.FeatureBuildItem;
+import io.quarkus.mutiny.runtime.MutinyInfrastructure;
 
 public class MutinyProcessor {
 
@@ -9,4 +15,11 @@ public class MutinyProcessor {
     public FeatureBuildItem registerFeature() {
         return new FeatureBuildItem(FeatureBuildItem.MUTINY);
     }
+
+    @BuildStep
+    @Record(ExecutionTime.RUNTIME_INIT)
+    public void initExecutor(ExecutorBuildItem executorBuildItem, MutinyInfrastructure recorder) {
+        ExecutorService executor = executorBuildItem.getExecutorProxy();
+        recorder.configureMutinyInfrastructure(executor);
+    }
 }
diff --git a/extensions/mutiny/runtime/src/main/java/io/quarkus/mutiny/runtime/MutinyInfrastructure.java b/extensions/mutiny/runtime/src/main/java/io/quarkus/mutiny/runtime/MutinyInfrastructure.java
new file mode 100644
index 0000000000000..ce46feecd91dd
--- /dev/null
+++ b/extensions/mutiny/runtime/src/main/java/io/quarkus/mutiny/runtime/MutinyInfrastructure.java
@@ -0,0 +1,14 @@
+package io.quarkus.mutiny.runtime;
+
+import java.util.concurrent.ExecutorService;
+
+import io.quarkus.runtime.annotations.Recorder;
+import io.smallrye.mutiny.infrastructure.Infrastructure;
+
+@Recorder
+public class MutinyInfrastructure {
+
+    public void configureMutinyInfrastructure(ExecutorService exec) {
+        Infrastructure.setDefaultExecutor(exec);
+    }
+}