AxMCPStreamableHTTPTransport
Extended by
Implements
Constructors
Constructor
new AxMCPStreamableHTTPTransport(mcpEndpoint: string, options: Readonly<AxMCPStreamableHTTPTransportOptions>): AxMCPStreamableHTTPTransport;Parameters
| Parameter | Type |
|---|---|
mcpEndpoint | string |
options | Readonly<AxMCPStreamableHTTPTransportOptions> |
Returns
AxMCPStreamableHTTPTransport
Methods
close()
close(): void;Returns
void
connect()
connect(): Promise<void>;Connects to the transport if needed This method is optional and only required for transports that need connection setup
Returns
Promise<void>
Implementation of
getHeaders()
getHeaders(): Record<string, string>;Returns
Record<string, string>
openListeningStream()
openListeningStream(): Promise<void>;Returns
Promise<void>
send()
send(message: Readonly<AxMCPJSONRPCRequest<unknown>>): Promise<AxMCPJSONRPCResponse<unknown>>;Sends a JSON-RPC request or notification and returns the response
Parameters
| Parameter | Type | Description |
|---|---|---|
message | Readonly<AxMCPJSONRPCRequest<unknown>> | The JSON-RPC request or notification to send |
Returns
Promise<AxMCPJSONRPCResponse<unknown>>
A Promise that resolves to the JSON-RPC response
Implementation of
sendNotification()
sendNotification(message: Readonly<AxMCPJSONRPCNotification>): Promise<void>;Sends a JSON-RPC notification
Parameters
| Parameter | Type | Description |
|---|---|---|
message | Readonly<AxMCPJSONRPCNotification> | The JSON-RPC notification to send |
Returns
Promise<void>
Implementation of
AxMCPTransport.sendNotification
sendResponse()
sendResponse(message: Readonly<AxMCPJSONRPCResponse>): Promise<void>;Sends a JSON-RPC response for a server-initiated request. Transports that cannot receive server requests do not need to implement it.
Parameters
| Parameter | Type |
|---|---|
message | Readonly<AxMCPJSONRPCResponse> |
Returns
Promise<void>
Implementation of
setAuthorization()
setAuthorization(authorization: string): void;Parameters
| Parameter | Type |
|---|---|
authorization | string |
Returns
void
setHeaders()
setHeaders(headers: Record<string, string>): void;Parameters
| Parameter | Type |
|---|---|
headers | Record<string, string> |
Returns
void
setMessageHandler()
setMessageHandler(handler: (message: Readonly<AxMCPJSONRPCMessage>) => void | Promise<void>): void;Registers a handler for server-initiated JSON-RPC requests and notifications that arrive outside a direct client request response.
Parameters
| Parameter | Type |
|---|---|
handler | (message: Readonly<AxMCPJSONRPCMessage>) => void | Promise<void> |
Returns
void
Implementation of
AxMCPTransport.setMessageHandler
setProtocolVersion()
setProtocolVersion(protocolVersion: string): void;Stores the negotiated MCP protocol version for transports that must emit it on later frames or HTTP requests.
Parameters
| Parameter | Type |
|---|---|
protocolVersion | string |
Returns
void
Implementation of
AxMCPTransport.setProtocolVersion
terminateSession()
terminateSession(): Promise<void>;Returns
Promise<void>