Struct WinxService 

pub struct WinxService {
    pub version: String,
    /* private fields */
}

Winx service. Holds the per-thread session registry.

Fields

version: String

Version information for the service

Implementations

impl WinxService

pub fn new() -> Self

Create a new WinxService for the local stdio transport (lenient, single-client session isolation).

pub fn with_isolation(isolation: SessionIsolation) -> Self

Create a WinxService with an explicit session-isolation policy. The HTTP transport uses SessionIsolation::Strict.

pub fn with_runtime( isolation: SessionIsolation, shell_runtime: Arc<dyn ShellRuntime>, ) -> Self

Create a service with an explicit shell-runtime boundary.

Trait Implementations

impl Clone for WinxService

fn clone(&self) -> WinxService

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for WinxService

fn default() -> Self

Returns the “default value” for a type.

impl ServerHandler for WinxService

ServerHandler implementation

fn get_info(&self) -> ServerInfo

async fn on_initialized(&self, context: NotificationContext<RoleServer>)

async fn on_roots_list_changed(&self, context: NotificationContext<RoleServer>)

fn get_tool(&self, name: &str) -> Option<Tool>

Get a tool definition by name.

async fn get_task( &self, request: GetTaskParams, _context: RequestContext<RoleServer>, ) -> Result<GetTaskResult, McpError>

SEP-2663 tasks/get: return the current DetailedTask state.

async fn update_task( &self, request: UpdateTaskParams, _context: RequestContext<RoleServer>, ) -> Result<(), McpError>

SEP-2663 tasks/update: accept responses to outstanding in-task input requests. Returns an empty acknowledgement on success.

async fn cancel_task( &self, request: CancelTaskParams, _context: RequestContext<RoleServer>, ) -> Result<(), McpError>

SEP-2663 tasks/cancel: cooperative cancellation. Returns an empty acknowledgement; the task’s observable status may lag.

async fn list_tools( &self, _request: Option<PaginatedRequestParams>, _context: RequestContext<RoleServer>, ) -> Result<ListToolsResult, McpError>

async fn list_resources( &self, _param: Option<PaginatedRequestParams>, _context: RequestContext<RoleServer>, ) -> Result<ListResourcesResult, McpError>

async fn list_prompts( &self, _request: Option<PaginatedRequestParams>, _context: RequestContext<RoleServer>, ) -> Result<ListPromptsResult, McpError>

async fn get_prompt( &self, request: GetPromptRequestParams, _context: RequestContext<RoleServer>, ) -> Result<GetPromptResponse, McpError>

async fn read_resource( &self, param: ReadResourceRequestParams, _context: RequestContext<RoleServer>, ) -> Result<ReadResourceResponse, McpError>

async fn call_tool( &self, param: CallToolRequestParams, context: RequestContext<RoleServer>, ) -> Result<CallToolResponse, McpError>

Handle a tools/call request from a client.

fn ping( &self, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + MaybeSendFuture

fn initialize( &self, request: InitializeRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<InitializeResult, ErrorData>> + MaybeSendFuture

fn supported_protocol_versions(&self) -> Cow<'static, [ProtocolVersion]>

Return the protocol versions supported by this server.

fn discover( &self, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<DiscoverResult, ErrorData>> + MaybeSendFuture

Return this server’s discovery information.

fn complete( &self, request: CompleteRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<CompleteResult, ErrorData>> + MaybeSendFuture

fn set_level( &self, request: SetLevelRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + MaybeSendFuture

fn list_resource_templates( &self, request: Option<PaginatedRequestParams>, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<ListResourceTemplatesResult, ErrorData>> + MaybeSendFuture

fn accepted_subscription_filter( &self, requested: &SubscriptionFilter, ) -> Option<SubscriptionFilter>

Return the subset of a requested notification filter this server accepts.

fn listen( &self, context: SubscriptionContext, ) -> impl Future<Output = Result<(), ErrorData>> + MaybeSendFuture

Run one established subscription until it is cancelled or closed gracefully.

fn subscribe( &self, request: SubscribeRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + MaybeSendFuture

👎Deprecated:

resources/subscribe is legacy-only; implement accepted_subscription_filter and listen for protocol version 2026-07-28

fn unsubscribe( &self, request: UnsubscribeRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + MaybeSendFuture

👎Deprecated:

resources/unsubscribe is legacy-only; subscriptions/listen is cancelled through its request lifecycle

fn on_custom_request( &self, request: CustomRequest, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<CustomResult, ErrorData>> + MaybeSendFuture

fn on_cancelled( &self, notification: CancelledNotificationParam, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + MaybeSendFuture

fn on_progress( &self, notification: ProgressNotificationParam, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + MaybeSendFuture

fn on_custom_notification( &self, notification: CustomNotification, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + MaybeSendFuture