Formatting fix

Author: Daniil Zulin

core/src/main/java/tech/ydb/core/impl/call/ReadStreamCall.java

@@ -60,28 +60,26 @@ public CompletableFuture<Status> start(Observer<RespT> observer) {
         }
 
         callLock.lock();
-
+        try {
+            call.start(this, headers);
+            if (logger.isTraceEnabled()) {
+                logger.trace("ReadStreamCall[{}] --> {}", traceId, TextFormat.shortDebugString((Message) request));
+            }
+            call.sendMessage(request);
+            // close stream by client side
+            call.halfClose();
+            call.request(1);
+        } catch (Throwable t) {
             try {
-                call.start(this, headers);
-                if (logger.isTraceEnabled()) {
-                    logger.trace("ReadStreamCall[{}] --> {}", traceId, TextFormat.shortDebugString((Message) request));
-                }
-                call.sendMessage(request);
-                // close stream by client side
-                call.halfClose();
-                call.request(1);
-            } catch (Throwable t) {
-                try {
-                    call.cancel(null, t);
-                } catch (Throwable ex) {
-                    logger.error("ReadStreamCall[{}] got exception while canceling", traceId, ex);
-                }
-
-                statusFuture.completeExceptionally(t);
-            } finally {
-                callLock.unlock();
+                call.cancel(null, t);
+            } catch (Throwable ex) {
+                logger.error("ReadStreamCall[{}] got exception while canceling", traceId, ex);
             }
 
+            statusFuture.completeExceptionally(t);
+        } finally {
+            callLock.unlock();
+        }
 
         return statusFuture;
     }

core/src/main/java/tech/ydb/core/impl/call/ReadWriteStreamCall.java

@@ -70,23 +70,21 @@ public CompletableFuture<Status> start(Observer<R> observer) {
         }
 
         callLock.lock();
-
+        try {
+            call.start(this, headers);
+            call.request(1);
+        } catch (Throwable t) {
             try {
-                call.start(this, headers);
-                call.request(1);
-            } catch (Throwable t) {
-                try {
-                    call.cancel(null, t);
-                } catch (Throwable ex) {
-                    logger.error("Exception encountered while closing the unary call", ex);
-                }
-
-                statusFuture.completeExceptionally(t);
-            } finally {
-
-                callLock.unlock();
+                call.cancel(null, t);
+            } catch (Throwable ex) {
+                logger.error("Exception encountered while closing the unary call", ex);
             }
 
+            statusFuture.completeExceptionally(t);
+        } finally {
+            callLock.unlock();
+        }
+
         return statusFuture;
     }