caproto.asyncio.server.VirtualCircuit

class caproto.asyncio.server.VirtualCircuit(circuit: caproto.server.common.VirtualCircuit, client: caproto.asyncio.utils._TransportWrapper, context: caproto.asyncio.server.Context, *, loop=None)

Wraps a caproto.VirtualCircuit with an asyncio client.

Methods

command_queue_loop()	Reference implementation of the command queue loop
get_from_sub_queue([timeout])
recv()	Receive bytes over TCP and cache them in this circuit’s buffer.
run()
send(*commands)	Process a command and tranport it over the TCP socket for this circuit.
subscription_queue_loop()