From d2f8d0e89b1c9b224ea9043502dc66bfe45ab582 Mon Sep 17 00:00:00 2001 From: Ian Saultz <52051793+atierian@users.noreply.github.com> Date: Mon, 28 Oct 2024 12:15:10 -0400 Subject: [PATCH] lint --- .../src/utils/appsync-graphql/subscription.ts | 20 +++++++++---------- 1 file changed, 10 insertions(+), 10 deletions(-) diff --git a/packages/amplify-graphql-api-construct-tests/src/utils/appsync-graphql/subscription.ts b/packages/amplify-graphql-api-construct-tests/src/utils/appsync-graphql/subscription.ts index 1faa08a994..fd4929dfe2 100644 --- a/packages/amplify-graphql-api-construct-tests/src/utils/appsync-graphql/subscription.ts +++ b/packages/amplify-graphql-api-construct-tests/src/utils/appsync-graphql/subscription.ts @@ -97,13 +97,13 @@ export class AppSyncConnection { } /** - * A client for connecting to an AppSync realtime endpoint. - * - * @example - * const client = new AppSyncSubscriptionClient(realtimeEndpoint, graphqlEndpoint); - * const connection = await client.connect(auth); - * const subscription = connection.subscribe({ query, variables, auth }); -*/ + * A client for connecting to an AppSync realtime endpoint. + * + * @example + * const client = new AppSyncSubscriptionClient(realtimeEndpoint, graphqlEndpoint); + * const connection = await client.connect(auth); + * const subscription = connection.subscribe({ query, variables, auth }); + */ export class AppSyncSubscriptionClient { ws: WebSocket; @@ -266,7 +266,7 @@ export const mergeNamedAsyncIterators = async function* ( pending.add(promise); // When this promise resolves, remove it from pending and add result if valid - promise.then(result => { + promise.then((result) => { pending.delete(promise); if (result) { results.push(result); @@ -301,9 +301,9 @@ export const mergeNamedAsyncIterators = async function* ( const values = await consumeYields(subscription, 3); */ export async function consumeYields(iterator: AsyncIterableIterator, numYields: number): Promise> { - const yieldsPromises = Array.from({ length: numYields }, () => iterator.next().then(({ value, done }) => done ? undefined : value)); + const yieldsPromises = Array.from({ length: numYields }, () => iterator.next().then(({ value, done }) => (done ? undefined : value))); const yields = await Promise.all(yieldsPromises); return yields; } -// #endregion async iterator utilities \ No newline at end of file +// #endregion async iterator utilities