Skip to content

Commit c31799d

Browse files
committed
fix async request porcessing
1 parent 7f84d9b commit c31799d

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
@@ -1834,10 +1834,10 @@ class ApiGateway {
18341834
if (props.queryType === 'multi') {
18351835
// We prepare the final json result on native side
18361836
const resultMulti = new ResultMultiWrapper(results, { queryType, slowQuery });
1837-
res(resultMulti);
1837+
return res(resultMulti);
18381838
} else {
18391839
// We prepare the full final json result on native side
1840-
res(results[0]);
1840+
return res(results[0]);
18411841
}
18421842
} catch (e: any) {
18431843
this.handleError({
@@ -1936,7 +1936,7 @@ class ApiGateway {
19361936
}];
19371937
}
19381938

1939-
res(request.streaming ? results[0] : { results });
1939+
return res(request.streaming ? results[0] : { results });
19401940
} else {
19411941
results = await Promise.all(
19421942
normalizedQueries.map(async (normalizedQuery, index) => {
@@ -1970,11 +1970,11 @@ class ApiGateway {
19701970
);
19711971

19721972
if (request.streaming) {
1973-
res(results[0]);
1973+
return res(results[0]);
19741974
} else {
19751975
// We prepare the final json result on native side
19761976
const resultArray = new ResultArrayWrapper(results);
1977-
res(resultArray);
1977+
return res(resultArray);
19781978
}
19791979
}
19801980
} catch (e: any) {

0 commit comments

Comments
 (0)