(uri: string)
| 960 | }; |
| 961 | |
| 962 | const subscribeToResource = async (uri: string) => { |
| 963 | if (!resourceSubscriptions.has(uri)) { |
| 964 | await sendMCPRequest( |
| 965 | { |
| 966 | method: "resources/subscribe" as const, |
| 967 | params: { uri }, |
| 968 | }, |
| 969 | z.object({}), |
| 970 | "resources", |
| 971 | ); |
| 972 | const clone = new Set(resourceSubscriptions); |
| 973 | clone.add(uri); |
| 974 | setResourceSubscriptions(clone); |
| 975 | } |
| 976 | }; |
| 977 | |
| 978 | const unsubscribeFromResource = async (uri: string) => { |
| 979 | if (resourceSubscriptions.has(uri)) { |
no test coverage detected