Skip to content

Commit

Permalink
fix(stream): add await inside async try catch block
Browse files Browse the repository at this point in the history
  • Loading branch information
vitoke committed Jun 2, 2022
1 parent 9042001 commit 59e368f
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion deno_dist/stream/async-custom/async-stream-custom.ts
Original file line number Diff line number Diff line change
@@ -726,7 +726,7 @@ export abstract class AsyncStreamBase<T> implements AsyncStream<T> {
index++;
}

return Promise.all(
return await Promise.all(
state.map((s: any, i: any): unknown => reducers[i].stateToResult(s))
);
} catch (e) {
2 changes: 1 addition & 1 deletion packages/stream/src/async-custom/async-stream-custom.ts
Original file line number Diff line number Diff line change
@@ -726,7 +726,7 @@ export abstract class AsyncStreamBase<T> implements AsyncStream<T> {
index++;
}

return Promise.all(
return await Promise.all(
state.map((s: any, i: any): unknown => reducers[i].stateToResult(s))
);
} catch (e) {

0 comments on commit 59e368f

Please sign in to comment.