Class JsonRpcIoHandler

java.lang.Object

dev.langchain4j.mcp.transport.stdio.JsonRpcIoHandler

All Implemented Interfaces:

Closeable, AutoCloseable, Runnable

public class JsonRpcIoHandler
extends Object
implements Runnable, Closeable

Constructor Summary

Constructors

Constructor	Description
JsonRpcIoHandler(InputStream input, OutputStream output, Consumer<com.fasterxml.jackson.databind.JsonNode> messageHandler, boolean logEvents)
JsonRpcIoHandler(InputStream input, OutputStream output, Consumer<com.fasterxml.jackson.databind.JsonNode> messageHandler, boolean logEvents, org.slf4j.Logger logger)

Method Summary

Modifier and Type	Method	Description
void	close()
void	run()
void	submit(String message)

Methods inherited from class Object

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

Constructor Details

JsonRpcIoHandler

public JsonRpcIoHandler(InputStream input,
 OutputStream output,
 Consumer<com.fasterxml.jackson.databind.JsonNode> messageHandler,
 boolean logEvents)

JsonRpcIoHandler

public JsonRpcIoHandler(InputStream input,
 OutputStream output,
 Consumer<com.fasterxml.jackson.databind.JsonNode> messageHandler,
 boolean logEvents,
 org.slf4j.Logger logger)

Method Details

run

public void run()

Specified by:

run in interface Runnable

submit

public void submit(String message)
            throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException