Xj dZddlZddlmZddlmZddlZddlZddlm Z m Z ddl m Z ddl mZe d dejedzdejedzfd Zy) aY Stdio Server Transport Module This module provides functionality for creating an stdio-based transport layer that can be used to communicate with an MCP client through standard input/output streams. Example usage: ``` async def run_server(): async with stdio_server() as (read_stream, write_stream): # read_stream contains incoming JSONRPCMessages from stdin # write_stream allows sending JSONRPCMessages to stdout server = await create_my_server() await server.run(read_stream, write_stream, init_options) anyio.run(run_server) ``` N)asynccontextmanager) TextIOWrapper)MemoryObjectReceiveStreamMemoryObjectSendStream)SessionMessagestdinstdoutcTKs9tjttjj dds8tjttj j dtjd\}tjd\}fd}fd}tj4d{}|j||j|||fdddd{y7>7#1d{7swYyxYww) z Server transport for stdio: this communicates with an MCP client by reading from the current process' stdin and writing to stdout. zutf-8replace)encodingerrors)r rcK 4d{23d{} tjj|}t |}j |d{N7T7K#t$r$}j |d{7Yd}~zd}~wwxYw796dddd{7y#1d{7swYyxYw#t j$r*t jjd{7YywxYww)N) typesJSONRPCMessagemodel_validate_json ExceptionsendranyioClosedResourceErrorlowlevel checkpoint)linemessageexcsession_messageread_stream_writerrs d/mnt/ssd/data/Dropbox/adrian/vault-secondbrain/venv/lib/python3.12/site-packages/mcp/server/stdio.py stdin_readerz"stdio_server..stdin_reader<s .) C C"'CC$!"'"6"6"J"J4"P '5W&=O,11/BBB CC%!055c::: ! C#( C C C C C(( ...++- - - .sC>B>A B>B)BA"BB)A$B)BB) B>"B$ B-B B B B) BB)B) B>"B%#B>(C>)B;/B2 0B;7B>:C>;B>>4C;2C53C;8C>:C;;C>cK 4d{23d{}|jjdd}j|dzd{jd{[7a7X7!7 6dddd{7y#1d{7swYyxYw#tj $r*tj jd{7YywxYww)NT)by_alias exclude_none )rmodel_dump_jsonwriteflushrrrr)rjsonr write_stream_readers r stdout_writerz#stdio_server..stdout_writerKs .* ) )-@))/*22BBD_cBdD ,,td{333 ,,.((  ))3(.A ) ) ) ) ) (( ...++- - - .sCBA-BBA5A/A55BA1B'A3(B-B/A51B3B5B6 BBBCBB BBCB4CCCCCCN) r wrap_filersysrbufferr create_memory_object_streamcreate_task_group start_soon) rr read_stream write_streamrr(tgrr's `` @@r stdio_serverr2!s  cii.>.>Yb cd szz/@/@7!ST',&G&G&J# (-(I(I!(L%L% ..&&(((B l# m$<''(((((((sHC D(DD(*D> D( D D(D(D%D D%!D()NN)__doc__r* contextlibriorranyio.lowlevelanyio.streams.memoryrr mcp.typesrmcp.shared.messager AsyncFilestrr2rr>sj( * R-)-*.6( ??3 $ &6( OOC 4 '6(6(r=