Как использовать подписку Prisma GraphQl в приложении узла - PullRequest
Новая
       55

Как использовать подписку Prisma GraphQl в приложении узла

0 голосов
/ 08 ноября 2018

Я следую этому руководству .Я пытаюсь прослушать подписку graphQL в моем приложении узла.У меня много проблем с реализацией этой подписки.Я пробовал несколько разных способов, перечисленных ниже, ни один из них не работает.

// converted to rxjs observables
from(PrismaClient.$subscribe.priority({
    mutation_in: "CREATED"
})).subscribe(
    (next) => {
        console.log("next", next);
    },
    () => {
        console.log("error");
    },
    () => {
        console.log("complete");
    }
);

// as promise
PrismaClient.$subscribe.priority({
    mutation_in: "CREATED"
}).then(
    (next) => {
        console.log("next", next);
    }
);

Оба они просто возвращаются в следующем: 

{ next: [Function: next],
  return: [Function: return],
  throw: [Function: throw],
  '@@asyncIterator': [Function] }

Я ожидаю, что он вернет priority, который был создан любымвремя новый создан.Тем не менее, он возвращается только один раз и сразу завершает и возвращает тот объект, который я перечислил выше.

Я понимаю, что это как-то связано с возвращением Promise<AsyncIterator<...>>, но я не уверен, как решить эту проблему.

Как создать подписку prisma graphql в приложении узла, используя prisma-client?Я также хотел бы преобразовать это в rxjs вместо использования promises.Я просто предпочитаю Observables.

1 Ответ

0 голосов
/ 09 ноября 2018

Вот предложение с Promises и async / await: 

const main = async () => {
  const subscription = await PrismaClient.$subscribe.priority({
    mutation_in: 'CREATED',
  })
  handleSubscription(subscription)
}

const handleSubscription = async (subscription) => {
  const result = await subscription.next()
  console.log('do stuff with', result.value)

  if (!result.done) {
    console.log('handle again')
    handleSubscription(subscription)
  }
  else {
    console.log('done')
  }
}

main().catch(e => console.error(e))
...