File tree Expand file tree Collapse file tree 2 files changed +4
-3
lines changed
mcp-core/src/main/java/io/modelcontextprotocol Expand file tree Collapse file tree 2 files changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -180,7 +180,7 @@ public void awaitForExit() {
180180 private void startErrorProcessing () {
181181 this .errorScheduler .schedule (() -> {
182182 try (BufferedReader processErrorReader = new BufferedReader (
183- new InputStreamReader (process .getErrorStream ()))) {
183+ new InputStreamReader (process .getErrorStream (), StandardCharsets . UTF_8 ))) {
184184 String line ;
185185 while (!isClosing && (line = processErrorReader .readLine ()) != null ) {
186186 try {
@@ -246,7 +246,8 @@ public Mono<Void> sendMessage(JSONRPCMessage message) {
246246 */
247247 private void startInboundProcessing () {
248248 this .inboundScheduler .schedule (() -> {
249- try (BufferedReader processReader = new BufferedReader (new InputStreamReader (process .getInputStream ()))) {
249+ try (BufferedReader processReader = new BufferedReader (
250+ new InputStreamReader (process .getInputStream (), StandardCharsets .UTF_8 ))) {
250251 String line ;
251252 while (!isClosing && (line = processReader .readLine ()) != null ) {
252253 try {
Original file line number Diff line number Diff line change @@ -200,7 +200,7 @@ private void startInboundProcessing() {
200200 inboundReady .tryEmitValue (null );
201201 BufferedReader reader = null ;
202202 try {
203- reader = new BufferedReader (new InputStreamReader (inputStream ));
203+ reader = new BufferedReader (new InputStreamReader (inputStream , StandardCharsets . UTF_8 ));
204204 while (!isClosing .get ()) {
205205 try {
206206 String line = reader .readLine ();
You can’t perform that action at this time.
0 commit comments