export async function* subscribeMessage(args: void, context: any): AsyncIterator<string> {
  while (true) {
    yield `Hello from WebSocket ${Math.random()}`;
    await new Promise(resolve => setTimeout(resolve, 1000));
  }
}