Package com.yapcli.mcp.transport

Class StreamableHttpTransport

java.lang.Object

com.yapcli.mcp.transport.StreamableHttpTransport

All Implemented Interfaces:

McpTransport, AutoCloseable

public class StreamableHttpTransport
extends Object
implements McpTransport

Constructor Summary

Constructors

Constructor	Description
StreamableHttpTransport(String url, Map<String,String> headers)

Method Summary

Modifier and Type	Method	Description
void	close()
void	onReceive(Consumer<com.fasterxml.jackson.databind.JsonNode> listener)
void	send(com.fasterxml.jackson.databind.JsonNode message)
String	transportName()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.yapcli.mcp.transport.McpTransport

processId, stderrLines

Constructor Details

StreamableHttpTransport

public StreamableHttpTransport(String url,
 Map<String,String> headers)

Method Details

send

public void send(com.fasterxml.jackson.databind.JsonNode message)
          throws IOException

Specified by:

send in interface McpTransport

Throws:

IOException

onReceive

public void onReceive(Consumer<com.fasterxml.jackson.databind.JsonNode> listener)

Specified by:

onReceive in interface McpTransport

transportName

public String transportName()

Specified by:

transportName in interface McpTransport

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface McpTransport