nvflare.fuel.f3.drivers.aio_conn module

class AioConnection(connector: ConnectorInfo, aio_ctx: AioContext, reader: StreamReader, writer: StreamWriter, secure: bool = False)[source]

Bases: Connection

close()[source]

Close connection

Raises:: CommError – If any errors

get_conn_properties() → dict[source]

Get connection specific properties, like peer address, TLS certificate etc

Raises:: CommError – If any errors

async read_loop()[source]

send_frame(frame: bytes | bytearray | memoryview | list)[source]

Send a SFM frame through the connection to the remote endpoint.

Parameters:: frame – The frame to be sent
Raises:: CommError – If any error happens while sending the frame