synloop

Fallback blocking event loop for transports that doesn't support AIO.

def synloop(
    obj: object,
    connection: object,
    consumer: object,
    blueprint: object,
    hub: object,
    qos: object,
    heartbeat: object,
    clock: object,
    hbrate: float = 2.0,
    kwargs: dict
) - > null

Fallback blocking event loop for transports that doesn't support AIO.

Parameters

Name	Type	Description
obj	object	The worker or consumer object responsible for task handling, pending operations, and connection management.
connection	object	The transport connection instance used to drain incoming events and manage network communication.
consumer	object	The message consumer that receives tasks and routes them to the task handler.
blueprint	object	The execution blueprint used to track the current operational state and signal when the loop should terminate.
hub	object	The event loop hub; it is reset upon failure to prevent stale callbacks from blocking re-registration.
qos	object	The Quality of Service object used to manage and update message prefetch limits during the loop.
heartbeat	object	The heartbeat configuration or monitor used to maintain the connection's liveness.
clock	object	The logical or system clock used for timing operations within the loop.
hbrate	float = 2.0	The rate at which AMQP heartbeats are sent, typically used when running in greenlet-based environments.
kwargs	dict	Additional keyword arguments passed to the loop implementation.

Returns

Type	Description
null	This function does not return a value; it blocks until the blueprint state changes or the connection is lost.