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 1303244Copy full SHA for 1303244
packages/stream-collector-browser/src/index.ts
@@ -1,9 +1,20 @@
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));
+ let res = new Uint8Array(0);
+ const reader = stream.getReader();
+ let isDone = false;
9
+ while(!isDone) {
10
+ const { done, value } = await reader.read();
11
+ if(value) {
12
+ const prior = res;
13
+ res = new Uint8Array(prior.length + value.length);
14
+ res.set(prior);
15
+ res.set(value, prior.length);
16
+ }
17
+ isDone = done;
18
19
+ return res;
20
};
0 commit comments