Error Publishing to Subscription using Inngest Realtime

[myhendry]

Hi, i setup inngest realtime following the instructions here Realtime docs. I am getting following error in my console

WRN error publishing to subscription caller=devserver error="failed to write msg: failed to write frame: failed to write frame header: write tcp [::1]:8288->[::1]:63350: write: broken pipe" subscription_id=2a17ea9b-e8c7-40d3-97a8-d27b279ace9d protocol=ws

I am able to complete my main job - to create a simple note. However, i am unable to get the realtime feedback publish(createNoteChannel().logs(Hello from ${runId}));

Hope an Inngest expert can help. thanks

Below is snippet of my code if it helps

inngest/create-note.ts

export const createNoteChannel = channel("create-note").addTopic(
  topic("logs").type<string>()
);

export const createNote = inngestClient.createFunction(
  { id: "create-note" },
  { event: "test/create.note" },
  async ({ event, step, publish, runId }) => {
    publish(createNoteChannel().logs(`Hello from ${runId}`));

    const { content, isPrivate, userId } = event.data;

    const notePromise = step.run("add-note", async () => {
      return await createNoteFn(content, isPrivate, userId);
    });

    const note = await notePromise;
    console.log("inngest createnote fn", note); // null

    return { note };
  }
);

inngest/client.ts

let app: Inngest | undefined;

export const getInngestApp = () => {
  return (app ??= new Inngest({
    id: typeof window !== "undefined" ? "client" : "server",
    middleware: [realtimeMiddleware()],
    eventKey: INNGEST_EVENT_KEY,
  }));
};

actions/inngest.ts

export type CreateNoteToken = Realtime.Token<
  typeof createNoteChannel,
  ["logs"]
>;

export async function fetchRealtimeSubscriptionToken(): Promise<CreateNoteToken> {
  const token = await getSubscriptionToken(getInngestApp(), {
    channel: createNoteChannel(),
    topics: ["logs"],
  });

  return token;
}