fixes supplied metrics subscriber for non-fusible case

OlegDokuka · OlegDokuka · commit 40a9d6abdc30 · 2019-03-17T02:07:08.000+02:00
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
@@ -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,

Original file line number	Diff line number	Diff line change
`@@ -50,7 +50,7 @@ public class Metrics {`
`50`	`50`	`}`
`51`	`51`	`} else {`
`52`	`52`	`if (subscriber instanceof Fuseable.ConditionalSubscriber) {`
`53`		`- return new MetricsFuseableConditionalSubscriber<>(`
	`53`	`+ return new MetricsConditionalSubscriber<>(`
`54`	`54`	`(Fuseable.ConditionalSubscriber<? super T>) subscriber,`
`55`	`55`	`next,`
`56`	`56`	`complete,`