Public declaration syntax from forge-py/src/forge/comm/channel.py
Original source SHA-256: 2d25831e013ea36b74f374405e2dc820a74ea1de5549d7beb7213793e9a30475
Function bodies and constant values are omitted. This is not the complete implementation.

Source line 17
class ChannelTransport()

Source line 43
def __init__(self, send_queue: asyncio.Queue[AgentMessage], recv_queue: asyncio.Queue[AgentMessage]) -> None

Source line 53
def create_pair(cls, capacity: int=32) -> tuple[ChannelTransport, ChannelTransport]

Source line 70
async def send(self, message: AgentMessage) -> None

Source line 83
async def receive(self) -> AgentMessage

Source line 98
def close(self) -> None