edits in result processing when streaming

Author: KSDaemon

packages/cubejs-api-gateway/src/gateway.ts

@@ -1955,7 +1955,9 @@ class ApiGateway {
           })
         );
 
-        if (!request.streaming) {
+        if (request.streaming) {
+          res(results[0]);
+        } else {
           // We prepare the final json result on native side
           const [transformDataJson, rawData, resultDataJson] = (results as {
             transformDataParams: any;
@@ -1971,8 +1973,6 @@ class ApiGateway {
           );
 
           res(await getFinalQueryResultArray(transformDataJson, rawData, resultDataJson));
-        } else {
-          res(results[0]);
         }
       }
     } catch (e: any) {

rust/cubeorchestrator/src/transport.rs

@@ -84,7 +84,7 @@ pub struct GroupingSet {
 
 // We can do nothing with JS functions here,
 // but to keep DTOs in sync with reality, let's keep it.
-type JsFunction = String;
+pub type JsFunction = String;
 
 #[derive(Debug, Clone, Serialize, Deserialize, Hash, Eq, PartialEq)]
 #[serde(rename_all = "camelCase")]