diff --git a/integration-tests/grpc-hibernate-reactive/src/main/java/com/example/reactive/ReactiveService.java b/integration-tests/grpc-hibernate-reactive/src/main/java/com/example/reactive/ReactiveService.java
index d76b9a1aef9e5..ca2f1d1faec6c 100644
--- a/integration-tests/grpc-hibernate-reactive/src/main/java/com/example/reactive/ReactiveService.java
+++ b/integration-tests/grpc-hibernate-reactive/src/main/java/com/example/reactive/ReactiveService.java
@@ -41,10 +41,13 @@ public Uni<Test.Empty> add(Test.Item request) {
     @Override
     public Multi<Test.Item> watch(Test.Empty request) {
         int contextId = contextChecker.newContextId("ReactiveService#watch");
+        Multi<Item> cached = broadcast.cache();
+        cached.subscribe().with(i -> {
+        });
         Multi<Test.Item> existing = Item.<Item> streamAll()
                 .map(item -> Test.Item.newBuilder().setText(item.text).build());
         return Multi.createBy().concatenating()
-                .streams(existing, broadcast.map(i -> i.text)
+                .streams(existing, cached.map(i -> i.text)
                         .map(Test.Item.newBuilder()::setText)
                         .map(Test.Item.Builder::build))
                 .onItem().invoke(