AxMCPStreambleHTTPTransport

Defined in: https://github.com/ax-llm/ax/blob/be56d0cb4027af0a3a23d397cd01a57261e362d4/src/ax/mcp/transports/httpStreamTransport.ts#L10

Implements

AxMCPTransport

Constructors

Constructor

new AxMCPStreambleHTTPTransport(mcpEndpoint: string, options?: AxMCPStreamableHTTPTransportOptions): AxMCPStreambleHTTPTransport;

Defined in: https://github.com/ax-llm/ax/blob/be56d0cb4027af0a3a23d397cd01a57261e362d4/src/ax/mcp/transports/httpStreamTransport.ts#L29

Parameters

Parameter	Type
`mcpEndpoint`	`string`
`options?`	`AxMCPStreamableHTTPTransportOptions`

Returns

AxMCPStreambleHTTPTransport

Methods

close()

close(): void;

Defined in: https://github.com/ax-llm/ax/blob/be56d0cb4027af0a3a23d397cd01a57261e362d4/src/ax/mcp/transports/httpStreamTransport.ts#L317

Returns

void

connect()

connect(): Promise<void>;

Defined in: https://github.com/ax-llm/ax/blob/be56d0cb4027af0a3a23d397cd01a57261e362d4/src/ax/mcp/transports/httpStreamTransport.ts#L68

Connects to the transport if needed This method is optional and only required for transports that need connection setup

Returns

Promise<void>

Implementation of

AxMCPTransport.connect

getHeaders()

getHeaders(): Record<string, string>;

Defined in: https://github.com/ax-llm/ax/blob/be56d0cb4027af0a3a23d397cd01a57261e362d4/src/ax/mcp/transports/httpStreamTransport.ts#L48

Returns

Record<string, string>

openListeningStream()

openListeningStream(): Promise<void>;

Defined in: https://github.com/ax-llm/ax/blob/be56d0cb4027af0a3a23d397cd01a57261e362d4/src/ax/mcp/transports/httpStreamTransport.ts#L72

Returns

Promise<void>

send()

send(message: Readonly<AxMCPJSONRPCRequest<unknown>>): Promise<AxMCPJSONRPCResponse<unknown>>;

Defined in: https://github.com/ax-llm/ax/blob/be56d0cb4027af0a3a23d397cd01a57261e362d4/src/ax/mcp/transports/httpStreamTransport.ts#L155

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

AxMCPTransport.send

sendNotification()

sendNotification(message: Readonly<AxMCPJSONRPCNotification>): Promise<void>;

Defined in: https://github.com/ax-llm/ax/blob/be56d0cb4027af0a3a23d397cd01a57261e362d4/src/ax/mcp/transports/httpStreamTransport.ts#L255

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

setAuthorization()

setAuthorization(authorization: string): void;

Defined in: https://github.com/ax-llm/ax/blob/be56d0cb4027af0a3a23d397cd01a57261e362d4/src/ax/mcp/transports/httpStreamTransport.ts#L44

Parameters

Parameter	Type
`authorization`	`string`

Returns

void

setHeaders()

setHeaders(headers: Record<string, string>): void;

Defined in: https://github.com/ax-llm/ax/blob/be56d0cb4027af0a3a23d397cd01a57261e362d4/src/ax/mcp/transports/httpStreamTransport.ts#L40

Parameters

Parameter	Type
`headers`	`Record`<`string`, `string`>

Returns

void

setMessageHandler()

setMessageHandler(handler: (message: 
  | AxMCPJSONRPCNotification
  | AxMCPJSONRPCRequest<unknown>) => void): void;

Defined in: https://github.com/ax-llm/ax/blob/be56d0cb4027af0a3a23d397cd01a57261e362d4/src/ax/mcp/transports/httpStreamTransport.ts#L60

Parameters

Parameter	Type
`handler`	(`message`: \| `AxMCPJSONRPCNotification` \| `AxMCPJSONRPCRequest`<`unknown`>) => `void`

Returns

void

terminateSession()

terminateSession(): Promise<void>;

Defined in: https://github.com/ax-llm/ax/blob/be56d0cb4027af0a3a23d397cd01a57261e362d4/src/ax/mcp/transports/httpStreamTransport.ts#L300

Returns

Promise<void>