public final class McpStreamableServerSession.McpStreamableServerSessionStream extends java.lang.Object implements McpLoggableSession
构造器和说明 |
---|
McpStreamableServerSessionStream(McpStreamableServerTransport transport)
Constructor accepting the dedicated transport representing the SSE stream.
|
限定符和类型 | 方法和说明 |
---|---|
void |
close()
Closes the session and releases any associated resources.
|
reactor.core.publisher.Mono<java.lang.Void> |
closeGracefully()
Closes the session and releases any associated resources asynchronously.
|
boolean |
isNotificationForLevelAllowed(McpSchema.LoggingLevel loggingLevel)
Allows checking whether a particular logging level is allowed.
|
reactor.core.publisher.Mono<java.lang.Void> |
sendNotification(java.lang.String method,
java.lang.Object params)
Sends a notification to the model client or server with parameters.
|
<T> reactor.core.publisher.Mono<T> |
sendRequest(java.lang.String method,
java.lang.Object requestParams,
com.fasterxml.jackson.core.type.TypeReference<T> typeRef)
Sends a request to the model counterparty and expects a response of type T.
|
void |
setMinLoggingLevel(McpSchema.LoggingLevel minLoggingLevel)
Set the minimum logging level for the client.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
sendNotification
public McpStreamableServerSessionStream(McpStreamableServerTransport transport)
transport
- request-specific SSE transport streampublic void setMinLoggingLevel(McpSchema.LoggingLevel minLoggingLevel)
McpLoggableSession
setMinLoggingLevel
在接口中 McpLoggableSession
minLoggingLevel
- The minimum logging levelpublic boolean isNotificationForLevelAllowed(McpSchema.LoggingLevel loggingLevel)
McpLoggableSession
isNotificationForLevelAllowed
在接口中 McpLoggableSession
loggingLevel
- the level to checkpublic <T> reactor.core.publisher.Mono<T> sendRequest(java.lang.String method, java.lang.Object requestParams, com.fasterxml.jackson.core.type.TypeReference<T> typeRef)
McpSession
This method handles the request-response pattern where a response is expected from the client or server. The response type is determined by the provided TypeReference.
sendRequest
在接口中 McpSession
T
- the type of the expected responsemethod
- the name of the method to be called on the counterpartyrequestParams
- the parameters to be sent with the requesttypeRef
- the TypeReference describing the expected response typepublic reactor.core.publisher.Mono<java.lang.Void> sendNotification(java.lang.String method, java.lang.Object params)
McpSession
Similar to McpSession.sendNotification(String)
but allows sending additional
parameters with the notification.
sendNotification
在接口中 McpSession
method
- the name of the notification method to be sent to the counterpartyparams
- parameters to be sent with the notificationpublic reactor.core.publisher.Mono<java.lang.Void> closeGracefully()
McpSession
closeGracefully
在接口中 McpSession
Mono
that completes when the session has been closed.public void close()
McpSession
close
在接口中 McpSession