diff --git a/rsocket-rpc-core/src/main/java/io/rsocket/rpc/metrics/Metrics.java b/rsocket-rpc-core/src/main/java/io/rsocket/rpc/metrics/Metrics.java
index 4a319c89..9df30c61 100644
--- a/rsocket-rpc-core/src/main/java/io/rsocket/rpc/metrics/Metrics.java
+++ b/rsocket-rpc-core/src/main/java/io/rsocket/rpc/metrics/Metrics.java
@@ -50,7 +50,7 @@ public class Metrics {
             }
           } else {
             if (subscriber instanceof Fuseable.ConditionalSubscriber) {
-              return new MetricsFuseableConditionalSubscriber<>(
+              return new MetricsConditionalSubscriber<>(
                   (Fuseable.ConditionalSubscriber<? super T>) subscriber,
                   next,
                   complete,