removes try/catch

data/src/main/java/com/microsoft/azure/kusto/data/ClientImpl.java

@@ -10,6 +10,7 @@
 import java.util.Iterator;
 import java.util.Map;
 import java.util.concurrent.TimeUnit;
+import java.util.function.Function;
 
 import org.apache.commons.lang3.StringUtils;
 import org.apache.http.ParseException;
@@ -422,23 +423,19 @@ private Mono<InputStream> executeStreamingQueryAsync(@NotNull KustoRequest kr) {
 
     private Mono<InputStream> executeStreamingQuery(String clusterEndpoint, KustoRequest kr,
             HttpTracing tracing, String authorizationToken) {
-        try {
+        return Mono.fromCallable(() -> {
             HttpRequest request = HttpRequestBuilder
                     .newPost(clusterEndpoint)
                     .createCommandPayload(kr)
                     .withTracing(tracing)
                     .withAuthorization(authorizationToken)
                     .build();
             long timeoutMs = determineTimeout(kr.getProperties(), kr.getCommandType(), clusterUrl);
-
-            // Get the response and trace the call
             return MonitoredActivity.wrap(
                     postToStreamingOutputAsync(request, timeoutMs, 0,
                             kr.getProperties().getRedirectCount()),
                     "ClientImpl.executeStreamingQuery", updateAndGetExecuteTracingAttributes(kr.getDatabase(), kr.getProperties()));
-        } catch (Exception e) {
-            return Mono.error(e);
-        }
+        }).flatMap(Function.identity());
     }
 
     private long determineTimeout(ClientRequestProperties properties, CommandType commandType, String clusterUrl) throws DataClientException {