diff --git a/src/Decoder.ts b/src/Decoder.ts
index 49ce7174..d0c539d2 100644
--- a/src/Decoder.ts
+++ b/src/Decoder.ts
@@ -140,6 +140,25 @@ export class Decoder {
 );
 }
 
+ async *decodeStream(stream: AsyncIterable<arraylike<number> &#124; Uint8Array>) {
+ for await (const buffer of stream) {
+ this.appendBuffer(buffer);
+
+ try {
+ while (true) {
+ const result = this.decodeSync();
+
+ yield result;
+ }
+ } catch (e) {
+ if (!(e instanceof DataViewIndexOutOfBoundsError)) {
+ throw e; // rethrow
+ }
+ // fallthrough
+ }
+ }
+ }
+
 async *decodeArrayStream(stream: AsyncIterable<arraylike<number> &#124; Uint8Array>) {
 let headerParsed = false;
 let decoded = false;
@@ -160,7 +179,7 @@ export class Decoder {
 
 try {
 while (true) {
- let result = this.decodeSync();
+ const result = this.decodeSync();
 
 yield result;
 
diff --git a/src/decodeAsync.ts b/src/decodeAsync.ts
index 71679edb..5f5ab7b4 100644
--- a/src/decodeAsync.ts
+++ b/src/decodeAsync.ts
@@ -22,7 +22,7 @@ export async function decodeAsync(
 return decoder.decodeOneAsync(stream);
 }
 
-export async function* decodeArrayStream(
+export function decodeArrayStream(
 streamLike: ReadableStreamLike<uint8array &#124; ArrayLike<number>>,
 options: DecodeAsyncOptions = defaultDecodeOptions,
 ) {
@@ -37,7 +37,23 @@ export async function* decodeArrayStream(
 options.maxExtLength,
 );
 
- for await (let item of decoder.decodeArrayStream(stream)) {
- yield item;
- }
+ return decoder.decodeArrayStream(stream);
+}
+
+export function decodeStream(
+ streamLike: ReadableStreamLike<uint8array &#124; ArrayLike<number>>,
+ options: DecodeAsyncOptions = defaultDecodeOptions,
+) {
+ const stream = ensureAsyncIterabe(streamLike);
+
+ const decoder = new Decoder(
+ options.extensionCodec,
+ options.maxStrLength,
+ options.maxBinLength,
+ options.maxArrayLength,
+ options.maxMapLength,
+ options.maxExtLength,
+ );
+
+ return decoder.decodeStream(stream);
 }
diff --git a/test/decodeStream.test.ts b/test/decodeStream.test.ts
new file mode 100644
index 00000000..41d1e4f2
--- /dev/null
+++ b/test/decodeStream.test.ts
@@ -0,0 +1,30 @@
+import assert from "assert";
+import { encode } from "../src";
+import { decodeStream } from "../src/decodeAsync";
+
+describe("decodeStream", () => {
+ it("decodes stream", async () => {
+ const items = [
+ "foo",
+ 10,
+ {
+ name: "bar",
+ },
+ [1, 2, 3],
+ ];
+
+ const createStream = async function*() {
+ for (const item of items) {
+ yield encode(item);
+ }
+ };
+
+ const result = [];
+
+ for await (const item of decodeStream(createStream())) {
+ result.push(item);
+ }
+
+ assert.deepStrictEqual(result, items);
+ });
+});
</div><div class="naked_ctrl">
<form action="/index.cgi/contrast" method="get" name="gate">
<p><a href="http://altstyle.alfasado.net">AltStyle</a> によって変換されたページ <a href="https://patch-diff.githubusercontent.com/raw/msgpack/msgpack-javascript/pull/46.diff">(-&gt;オリジナル)</a>
/ <label>アドレス: <input type="text" name="naked_post_url" value="https://patch-diff.githubusercontent.com/raw/msgpack/msgpack-javascript/pull/46.diff" size="22" /></label> <label>モード: <select name="naked_post_mode">
<option value="default">デフォルト</option>
<option value="speech">音声ブラウザ</option>
<option value="ruby">ルビ付き</option>
<option value="contrast" selected="selected">配色反転</option>
<option value="larger-text">文字拡大</option>
<option value="mobile">モバイル</option>
</select>
<input type="submit" value="表示" />
</p>
</form>
</div>