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