How to use GraphQL Subscription with Cloudflare Workers?

[pyk]

Hey guys, there is an example on how to create graphql subscription here cloudflare workers

graphql-yoga/examples/cloudflare-advanced/src/index.ts

Lines 77 to 86 in e238bf6

	subscribe: () =>
	new Repeater((push, end) => {
	const interval = setInterval(
	() => push(new Date().toISOString()),
	1000,
	)
	end.then(() => clearInterval(interval))
	}),
	resolve: (value) => value,
	},

but it’s unclear how to publish message inside mutation and broadcast it in the subscription resolver.

For example, how to enable the subscription for this mutation so that the subscriber get notified on new ToDo?

graphql-yoga/examples/cloudflare-advanced/src/index.ts

Lines 54 to 59 in e238bf6

	Mutation: {
	addTodo: async (_, { content }) => {
	const id = Date.now().toString()
	await EXAMPLE_KV.put(`todo_${Date.now()}`, content)
	return id
	},

thank you

[ardatan]

You can see here;
https://github.com/bubblydoo/graphql-workers-subscriptions

[pyk]

Thanks!