We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 2b06fe3 commit a7a041dCopy full SHA for a7a041d
1 file changed
kotlin-sdk-test/src/jvmTest/kotlin/io/modelcontextprotocol/kotlin/sdk/client/StdioClientTransportTest.kt
@@ -45,4 +45,24 @@ class StdioClientTransportTest : BaseTransportTest() {
45
process.waitFor()
46
process.destroy()
47
}
48
+
49
+ @Test
50
+ fun `should ignore first output messages`() = runTest {
51
+ val processBuilder = ProcessBuilder("/usr/bin/tee")
52
+ val process = processBuilder.start()
53
+ process.outputStream.write("Stdio server started".toByteArray())
54
55
+ val input = process.inputStream.asSource().buffered()
56
+ val output = process.outputStream.asSink().buffered()
57
58
+ val client = StdioClientTransport(
59
+ input = input,
60
+ output = output,
61
+ )
62
63
+ testClientRead(client)
64
65
+ process.waitFor()
66
+ process.destroy()
67
+ }
68
0 commit comments