Skip to content

Commit 9713b31

Browse files
committed
fixed format
1 parent dd89416 commit 9713b31

File tree

1 file changed

+16
-3
lines changed
  • rsocket-rpc-core/src/main/java/io/rsocket/rpc/metrics

1 file changed

+16
-3
lines changed

rsocket-rpc-core/src/main/java/io/rsocket/rpc/metrics/Metrics.java

Lines changed: 16 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -37,13 +37,26 @@ public class Metrics {
3737
(scannable, subscriber) -> {
3838
if (scannable instanceof Fuseable) {
3939
if (subscriber instanceof Fuseable.ConditionalSubscriber) {
40-
return new MetricsFuseableConditionalSubscriber<>((Fuseable.ConditionalSubscriber<? super T>) subscriber, next, complete, error, cancelled, timer);
40+
return new MetricsFuseableConditionalSubscriber<>(
41+
(Fuseable.ConditionalSubscriber<? super T>) subscriber,
42+
next,
43+
complete,
44+
error,
45+
cancelled,
46+
timer);
4147
} else {
42-
return new MetricsFuseableSubscriber<>(subscriber, next, complete, error, cancelled, timer);
48+
return new MetricsFuseableSubscriber<>(
49+
subscriber, next, complete, error, cancelled, timer);
4350
}
4451
} else {
4552
if (subscriber instanceof Fuseable.ConditionalSubscriber) {
46-
return new MetricsFuseableConditionalSubscriber<>((Fuseable.ConditionalSubscriber<? super T>) subscriber, next, complete, error, cancelled, timer);
53+
return new MetricsFuseableConditionalSubscriber<>(
54+
(Fuseable.ConditionalSubscriber<? super T>) subscriber,
55+
next,
56+
complete,
57+
error,
58+
cancelled,
59+
timer);
4760
} else {
4861
return new MetricsSubscriber<>(subscriber, next, complete, error, cancelled, timer);
4962
}

0 commit comments

Comments
 (0)