Skip to content

LinkEndpoint

autogen.beta.network.transport.link.LinkEndpoint #

Bases: Protocol

Hub-side handle to one connected client.

Lives for the duration of a single connection; replaced on reconnect (the HubClient re-opens after a transport drop).

endpoint_id instance-attribute #

endpoint_id

agent_id instance-attribute #

agent_id

send_frame async #

send_frame(frame)

Push a frame towards the client.

Source code in autogen/beta/network/transport/link.py
async def send_frame(self, frame: Frame) -> None:
    """Push a frame towards the client."""
    ...

frames #

frames()

Async iterator of inbound frames from the client.

Source code in autogen/beta/network/transport/link.py
def frames(self) -> AsyncIterator[Frame]:
    """Async iterator of inbound frames from the client."""
    ...

close async #

close()

Drain queues, signal close to the client-side handler.

Source code in autogen/beta/network/transport/link.py
async def close(self) -> None:
    """Drain queues, signal close to the client-side handler."""
    ...