Skip to content

Commit da9bcc0

Browse files
committed
fix async request porcessing
1 parent 9f00c61 commit da9bcc0

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

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

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1814,10 +1814,10 @@ class ApiGateway {
18141814
if (props.queryType === 'multi') {
18151815
// We prepare the final json result on native side
18161816
const resultMulti = new ResultMultiWrapper(results, { queryType, slowQuery });
1817-
res(resultMulti);
1817+
return res(resultMulti);
18181818
} else {
18191819
// We prepare the full final json result on native side
1820-
res(results[0]);
1820+
return res(results[0]);
18211821
}
18221822
} catch (e: any) {
18231823
this.handleError({
@@ -1914,7 +1914,7 @@ class ApiGateway {
19141914
}];
19151915
}
19161916

1917-
res(request.streaming ? results[0] : { results });
1917+
return res(request.streaming ? results[0] : { results });
19181918
} else {
19191919
results = await Promise.all(
19201920
normalizedQueries.map(async (normalizedQuery, index) => {
@@ -1948,11 +1948,11 @@ class ApiGateway {
19481948
);
19491949

19501950
if (request.streaming) {
1951-
res(results[0]);
1951+
return res(results[0]);
19521952
} else {
19531953
// We prepare the final json result on native side
19541954
const resultArray = new ResultArrayWrapper(results);
1955-
res(resultArray);
1955+
return res(resultArray);
19561956
}
19571957
}
19581958
} catch (e: any) {

0 commit comments

Comments
 (0)