Skip to content

Commit 9a84aa6

Browse files
committed
fix a typo
1 parent 23f30e1 commit 9a84aa6

File tree

2 files changed

+5
-5
lines changed

2 files changed

+5
-5
lines changed

src/decodeAsync.ts

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,13 +1,13 @@
11
import { Decoder } from "./Decoder";
22
import { defaultDecodeOptions, DecodeOptions } from "./decode";
3-
import { ensureAsyncIterabe, ReadableStreamLike } from "./utils/stream";
3+
import { ensureAsyncIterable, ReadableStreamLike } from "./utils/stream";
44
import { SplitUndefined } from "./context";
55

66
export async function decodeAsync<ContextType>(
77
streamLike: ReadableStreamLike<ArrayLike<number>>,
88
options: DecodeOptions<SplitUndefined<ContextType>> = defaultDecodeOptions as any,
99
): Promise<unknown> {
10-
const stream = ensureAsyncIterabe(streamLike);
10+
const stream = ensureAsyncIterable(streamLike);
1111

1212
const decoder = new Decoder(
1313
options.extensionCodec,
@@ -25,7 +25,7 @@ export function decodeArrayStream<ContextType>(
2525
streamLike: ReadableStreamLike<ArrayLike<number>>,
2626
options: DecodeOptions<SplitUndefined<ContextType>> = defaultDecodeOptions as any,
2727
) {
28-
const stream = ensureAsyncIterabe(streamLike);
28+
const stream = ensureAsyncIterable(streamLike);
2929

3030
const decoder = new Decoder(
3131
options.extensionCodec,
@@ -44,7 +44,7 @@ export function decodeStream<ContextType>(
4444
streamLike: ReadableStreamLike<ArrayLike<number>>,
4545
options: DecodeOptions<SplitUndefined<ContextType>> = defaultDecodeOptions as any,
4646
) {
47-
const stream = ensureAsyncIterabe(streamLike);
47+
const stream = ensureAsyncIterable(streamLike);
4848

4949
const decoder = new Decoder(
5050
options.extensionCodec,

src/utils/stream.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ export async function* asyncIterableFromStream<T>(stream: ReadableStream<T>): As
3333
}
3434
}
3535

36-
export function ensureAsyncIterabe<T>(streamLike: ReadableStreamLike<T>): AsyncIterable<T> {
36+
export function ensureAsyncIterable<T>(streamLike: ReadableStreamLike<T>): AsyncIterable<T> {
3737
if (isAsyncIterable(streamLike)) {
3838
return streamLike;
3939
} else {

0 commit comments

Comments
 (0)