Using async generators and fetch api to query graphql

async-graphql-request.ts

export const initGraphql = (input: RequestInfo, accessKey?: string) =>
  async function* asyncFetch(query: any, variables?: any) {
    while (true) {
      const response = await fetch(input, {
        method: 'POST',
        headers: accessKey
          ? {
              'Content-Type': 'application/json',
              'x-hasura-access-key': accessKey,
            }
          : undefined,
        body: JSON.stringify({
          query,
          variables,
        }),
        cache: 'force-cache',
      })
      const responseJSON = await response.json()
      if (responseJSON) yield responseJSON
      else return
    }
  }

export const request = initGraphql(
  process.env.GRAPHQL_ENDPOINT as string,
  process.env.HASURA_ACCESS_KEY as string,
)

async function example() {
  for await (const { data } of request(my_graphql_query)) {
    console.log(data)
    if (data) break
  }
}

example()