Function safeEnqueue

src/adapters.ts:118–120

(data: Uint8Array)

      let streamClosed = false;

      const safeEnqueue = (data: Uint8Array) => {
        if (!streamClosed) controller.enqueue(data);
      };

      const sendMessageStart = () => {
        safeEnqueue(encoder.encode(`event: message_start\ndata: ${JSON.stringify({