Skip to content

Commit 1d3fe0e

Browse files
committed
fix: AsyncIterableIterator
1 parent 7a0944c commit 1d3fe0e

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

src/pubsub-async-iterator.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ import { PubSubEngine } from 'graphql-subscriptions';
2929
* @property pubsub @type {PubSubEngine}
3030
* The PubSubEngine whose events will be observed.
3131
*/
32-
export class PubSubAsyncIterator<T> implements AsyncIterator<T> {
32+
export class PubSubAsyncIterator<T> implements AsyncIterableIterator<T> {
3333

3434
constructor(pubsub: PubSubEngine, eventNames: string | string[], options?: unknown) {
3535
this.pubsub = pubsub;

src/with-filter.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
export type FilterFn = (rootValue?: any, args?: any, context?: any, info?: any) => boolean;
22

3-
export const withFilter = (asyncIteratorFn: () => AsyncIterator<any>, filterFn: FilterFn) => {
3+
export const withFilter = (asyncIteratorFn: () => AsyncIterableIterator<any>, filterFn: FilterFn) => {
44
return (rootValue: any, args: any, context: any, info: any): AsyncIterator<any> => {
55
const asyncIterator = asyncIteratorFn();
66

0 commit comments

Comments
 (0)