(
read_stream: ReadStream[SessionMessage | Exception],
write_stream: WriteStream[SessionMessage],
client_info: types.Implementation | None = None,
)
| 33 | |
| 34 | |
| 35 | async def run_session( |
| 36 | read_stream: ReadStream[SessionMessage | Exception], |
| 37 | write_stream: WriteStream[SessionMessage], |
| 38 | client_info: types.Implementation | None = None, |
| 39 | ): |
| 40 | async with ClientSession( |
| 41 | read_stream, |
| 42 | write_stream, |
| 43 | message_handler=message_handler, |
| 44 | client_info=client_info, |
| 45 | ) as session: |
| 46 | logger.info("Initializing session") |
| 47 | await session.initialize() |
| 48 | logger.info("Initialized") |
| 49 | |
| 50 | |
| 51 | async def main(command_or_url: str, args: list[str], env: list[tuple[str, str]]): |
no test coverage detected