We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent dae6d08 commit f81ff29Copy full SHA for f81ff29
packages/stream-collector-browser/src/index.ts
@@ -1,9 +1,17 @@
1
import { StreamCollector } from "@aws-sdk/types";
2
3
-export const streamCollector: StreamCollector = (
4
- stream: ReadableStream
+export const streamCollector: StreamCollector = async (
+ stream: ReadableStream<Uint8Array>
5
): Promise<Uint8Array> => {
6
- return new Response(stream)
7
- .arrayBuffer()
8
- .then(arrayBuffer => new Uint8Array(arrayBuffer));
+ const res: number[] = [];
+ const reader = stream.getReader();
+ let isDone = false;
9
+ while(!isDone) {
10
+ const { done, value } = await reader.read();
11
+ if(value) {
12
+ res.push(...value);
13
+ }
14
+ isDone = done;
15
16
+ return new Uint8Array(res);
17
};
0 commit comments