55import 'dart:io' ;
66
77import 'package:dart_mcp/client.dart' ;
8+ import 'package:dart_mcp/stdio.dart' ;
89import 'package:test/test.dart' ;
910
1011void main () {
@@ -19,23 +20,25 @@ void main() {
1920 'mcp-server' ,
2021 if (withExperiment) '--experimental-mcp-server' ,
2122 ]);
22- final serverConnection = client.connectStdioServer (
23- process.stdin, process.stdout,
24- onDone: process.kill);
25- final initializeResult = await serverConnection.initialize (
26- InitializeRequest (
27- protocolVersion: ProtocolVersion .latestSupported,
28- capabilities: client.capabilities,
29- clientInfo: client.implementation));
23+
24+ final connection = client.connectServer (
25+ stdioChannel (input: process.stdout, output: process.stdin),
26+ );
27+ connection.done.then ((_) => process.kill ());
28+
29+ final initializeResult = await connection.initialize (
30+ InitializeRequest (
31+ protocolVersion: ProtocolVersion .latestSupported,
32+ capabilities: client.capabilities,
33+ clientInfo: client.implementation,
34+ ),
35+ );
3036
3137 expect (
3238 initializeResult.protocolVersion, ProtocolVersion .latestSupported);
33- serverConnection .notifyInitialized ();
39+ connection .notifyInitialized ();
3440
35- expect (
36- await serverConnection.listTools (ListToolsRequest ()),
37- isNotEmpty,
38- );
41+ expect (await connection.listTools (ListToolsRequest ()), isNotEmpty);
3942 });
4043 }
4144 });
0 commit comments