Subscriptions with redis

[ajmerik121]

Why do I get always get this error when I try to listen to events from redis

Redis library for subscriptions
graphql-redis-subscriptions

Error
Internal error occurred during message handling. Please check your implementation. Error: Subscription field must return Async Iterable. Received: { subscribe: [function subscribe] }.

Example schema
const schema = buildSchema(` type Query { hello: String } type Subscription { messages: String! } `);

Example resolvers
const roots = { query: { hello: () => 'Hello World!', }, subscription: { messages: { subscribe : async () => await pubsub.asyncIterator("MESSAGE_ADDED") } }, };

[enisdenjo]

Hey there, the error messages describes exactly what the issue is, you've read it right?

const roots = {
  query: { hello: () => 'Hello World!' },
  subscription: {
-   messages: {
-     subscribe: async () => await pubsub.asyncIterator('MESSAGE_ADDED'),
-   },
+   messages: async () => await pubsub.asyncIterator('MESSAGE_ADDED'),
  },
};

See also: #205 (comment).