modelcontextprotocol/typescript-sdk
Watch
1
0
Fork
You've already forked typescript-sdk
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 1

Merge branch 'ihrpr/streamable-http-client' into ihrpr/fix-streamable-connection-close

Browse source
This commit is contained in:
ihrpr 2025-04-08 22:31:02 +01:00
commit ddf3d5dda5
No known key found for this signature in database
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
src/client/streamableHttp.ts
View file

@ -2,7 +2,7 @@ import { Transport } from "../shared/transport.js";
import { JSONRPCMessage, JSONRPCMessageSchema } from "../types.js";
import { auth, AuthResult, OAuthClientProvider, UnauthorizedError } from "./auth.js";
import { type ErrorEvent } from "eventsource";
import { EventSourceParserStream } from 'eventsource-parser/stream';
import { EventSourceMessage, EventSourceParserStream } from 'eventsource-parser/stream';
export class StreamableHTTPError extends Error {
constructor(
public readonly code: number | undefined,
@ -45,7 +45,7 @@ export type StreamableHTTPClientTransportOptions = {
* for receiving messages.
*/
export class StreamableHTTPClientTransport implements Transport {
private _activeStreams: Map<string, ReadableStreamDefaultReader<any>> = new Map();
private _activeStreams: Map<string, ReadableStreamDefaultReader<EventSourceMessage>> = new Map();
private _abortController?: AbortController;
private _url: URL;
private _requestInit?: RequestInit;