Polish gh-132

src/main/java/ru/rt/restream/reindexer/binding/cproto/CommandObservationContext.java

@@ -47,7 +47,7 @@ final class CommandObservationContext extends RequestReplySenderContext<Object,
 
     private RemoteServerAddress remoteServerAddress;
 
-    CommandObservationContext(int command, Object[] arguments) {
+    CommandObservationContext(int command, Object... arguments) {
         super((carrier, key, value) -> {}, Kind.CLIENT);
         this.command = command;
         this.arguments = arguments;

src/main/java/ru/rt/restream/reindexer/binding/cproto/ObservationDataSource.java

@@ -54,20 +54,15 @@ private final class ObservationConnection implements Connection {
         public ReindexerResponse rpcCall(int command, Object... args) {
             CommandObservationContext context = new CommandObservationContext(command, args);
             context.setRemoteServiceAddress(url);
-            Observation observation = Observation.createNotStarted(CONVENTION, () -> context, registry).start();
-            try (Observation.Scope scope = observation.openScope()) {
+            Observation observation = Observation.createNotStarted(CONVENTION, () -> context, registry);
+            return observation.observe(() -> {
                 ReindexerResponse response = delegate.rpcCall(command, args);
                 context.setResponse(response);
                 if (response.hasError()) {
                     observation.error(ReindexerExceptionFactory.fromResponse(response));
                 }
                 return response;
-            } catch (Throwable t) {
-                observation.error(t);
-                throw t;
-            } finally {
-                observation.stop();
-            }
+            });
         }
 
         @Override