refactor: correct loop syntax for synchronous iterations

src/examples/server/simpleSseServer.ts

@@ -158,7 +158,7 @@ process.on('SIGINT', async () => {
   console.log('Shutting down server...');
 
   // Close all active transports to properly clean up resources
-  for (const sessionId in transports) {
+  for await (const sessionId of Object.keys(transports)) {
     try {
       console.log(`Closing transport for session ${sessionId}`);
       await transports[sessionId].close();

src/examples/server/simpleStreamableHttp.ts

@@ -661,7 +661,7 @@ process.on('SIGINT', async () => {
   console.log('Shutting down server...');
 
   // Close all active transports to properly clean up resources
-  for (const sessionId in transports) {
+  for await (const sessionId of Object.keys(transports)) {
     try {
       console.log(`Closing transport for session ${sessionId}`);
       await transports[sessionId].close();

src/examples/server/sseAndStreamableHttpCompatibleServer.ts

@@ -243,7 +243,7 @@ process.on('SIGINT', async () => {
   console.log('Shutting down server...');
 
   // Close all active transports to properly clean up resources
-  for (const sessionId in transports) {
+  for await (const sessionId of Object.keys(transports)) {
     try {
       console.log(`Closing transport for session ${sessionId}`);
       await transports[sessionId].close();

src/examples/shared/inMemoryEventStore.ts

@@ -56,7 +56,7 @@ export class InMemoryEventStore implements EventStore {
     // Sort events by eventId for chronological ordering
     const sortedEvents = [...this.events.entries()].sort((a, b) => a[0].localeCompare(b[0]));
 
-    for (const [eventId, { streamId: eventStreamId, message }] of sortedEvents) {
+    for await (const [eventId, { streamId: eventStreamId, message }] of sortedEvents) {
       // Only include events from the same stream
       if (eventStreamId !== streamId) {
         continue;

src/server/auth/middleware/allowedMethods.test.ts

@@ -30,7 +30,7 @@ describe("allowedMethods", () => {
   test("returns 405 for unspecified HTTP methods", async () => {
     const methods = ["post", "put", "delete", "patch"];
 
-    for (const method of methods) {
+    for await (const method of methods) {
       // @ts-expect-error - dynamic method call
       const response = await request(app)[method]("/test");
       expect(response.status).toBe(405);

src/server/mcp.ts

@@ -365,7 +365,7 @@ export class McpServer {
         );
 
         const templateResources: Resource[] = [];
-        for (const template of Object.values(
+        for await (const template of Object.values(
           this._registeredResourceTemplates,
         )) {
           if (!template.resourceTemplate.listCallback) {

src/server/streamableHttp.test.ts

@@ -1285,7 +1285,7 @@ describe("StreamableHTTPServerTransport with resumability", () => {
       const streamId = lastEventId.split('_')[0];
       // Extract stream ID from the event ID
       // For test simplicity, just return all events with matching streamId that aren't the lastEventId
-      for (const [eventId, { message }] of storedEvents.entries()) {
+      for await (const [eventId, { message }] of storedEvents.entries()) {
         if (eventId.startsWith(streamId) && eventId !== lastEventId) {
           await send(eventId, message);
         }