Skip to content

Commit beb7b86

Browse files
committed
feat(push): accept Promise as argument to push
1 parent 1a067d9 commit beb7b86

File tree

1 file changed

+8
-3
lines changed

1 file changed

+8
-3
lines changed

index.ts

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -53,17 +53,22 @@ export async function* tail<T>(iterable: AsyncIterableLike<T>): AsyncIterable<T>
5353

5454
export const asyncTail = tail;
5555

56-
export async function* push<T>(iterable: AsyncIterableLike<T>, value: T): AsyncIterable<T> {
56+
export async function* push<T>(
57+
iterable: AsyncIterableLike<T>,
58+
value: T | Promise<T>
59+
): AsyncIterable<T> {
5760
for await (const element of await iterable) {
5861
yield element;
5962
}
6063

61-
yield value;
64+
yield await value;
6265
}
6366

6467
export const asyncPush = push;
6568

66-
export function pushFn<T>(value: T): (iterable: AsyncIterableLike<T>) => AsyncIterable<T> {
69+
export function pushFn<T>(
70+
value: T | Promise<T>
71+
): (iterable: AsyncIterableLike<T>) => AsyncIterable<T> {
6772
return iterable => push(iterable, value);
6873
}
6974

0 commit comments

Comments
 (0)