Skip to content

Commit aada734

Browse files
committed
add notification e2e tests
1 parent 345a850 commit aada734

File tree

2 files changed

+245
-85
lines changed

2 files changed

+245
-85
lines changed

src/commonMain/kotlin/io/modelcontextprotocol/kotlin/sdk/client/StreamableHttpClientTransport.kt

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@ import io.ktor.client.plugins.ClientRequestException
66
import io.ktor.client.plugins.sse.ClientSSESession
77
import io.ktor.client.plugins.sse.sseSession
88
import io.ktor.client.request.HttpRequestBuilder
9+
import io.ktor.client.request.accept
910
import io.ktor.client.request.delete
1011
import io.ktor.client.request.headers
1112
import io.ktor.client.request.post
@@ -223,7 +224,7 @@ public class StreamableHttpClientTransport(
223224
) {
224225
method = HttpMethod.Get
225226
applyCommonHeaders(this)
226-
headers.append(HttpHeaders.Accept, ContentType.Text.EventStream.toString())
227+
accept(ContentType.Text.EventStream)
227228
(resumptionToken ?: lastEventId)?.let { headers.append(MCP_RESUMPTION_TOKEN_HEADER, it) }
228229
requestBuilder()
229230
}
@@ -244,7 +245,6 @@ public class StreamableHttpClientTransport(
244245

245246
private fun applyCommonHeaders(builder: HttpRequestBuilder) {
246247
builder.headers {
247-
append(HttpHeaders.Accept, ContentType.Application.Json.toString())
248248
sessionId?.let { append(MCP_SESSION_ID_HEADER, it) }
249249
protocolVersion?.let { append(MCP_PROTOCOL_VERSION_HEADER, it) }
250250
}

0 commit comments

Comments
 (0)