chore: prettier formatting (streamDriver, taskManager)

Author: felixweinberger

packages/core/src/shared/streamDriver.ts

@@ -73,10 +73,7 @@ export class StreamDriver implements Outbound {
      * matched-handler dispatch / unknown-id error). Return `preserveProgress: true` to keep
      * the progress handler registered after the matched handler runs. Set by the owner.
      */
-    onresponse?: (
-        response: JSONRPCResponse | JSONRPCErrorResponse,
-        messageId: number
-    ) => { consumed: boolean; preserveProgress?: boolean };
+    onresponse?: (response: JSONRPCResponse | JSONRPCErrorResponse, messageId: number) => { consumed: boolean; preserveProgress?: boolean };
 
     constructor(
         // eslint-disable-next-line @typescript-eslint/no-explicit-any -- driver is context-agnostic; subclass owns ContextT

packages/core/src/shared/taskManager.ts

@@ -823,8 +823,7 @@ export class TaskManager {
         }
         return outbound.request(request, resultSchema, {
             ...options,
-            intercept: (wire, messageId, settle, onError) =>
-                this.processOutboundRequest(wire, options, messageId, settle, onError).queued
+            intercept: (wire, messageId, settle, onError) => this.processOutboundRequest(wire, options, messageId, settle, onError).queued
         });
     }
 

packages/server/src/server/mcpServer.ts

@@ -20,9 +20,9 @@ import type {
     JSONRPCErrorResponse,
     JSONRPCMessage,
     JSONRPCNotification,
-    JSONRPCResultResponse,
     JSONRPCRequest,
     JSONRPCResponse,
+    JSONRPCResultResponse,
     JsonSchemaType,
     jsonSchemaValidator,
     ListRootsRequest,
@@ -326,8 +326,7 @@ export class McpServer extends Dispatcher<ServerContext> implements RegistriesHo
                                   resolve(parsed.data as SchemaOutput<typeof schema>);
                               };
                               if (opts?.intercept?.(wire, id, finish, reject)) return;
-                              transport
-                                  .request!(wire)
+                              transport.request!(wire)
                                   .then(resp =>
                                       'error' in resp
                                           ? reject(ProtocolError.fromError(resp.error.code, resp.error.message, resp.error.data))