tqsdk.TqChan - 协程通信通道

class tqsdk.TqChan

用于协程间传递数据的通道。register_update_notify() 返回此类型， 可通过 async with 和 async for 接收更新通知。 更新通知的完整用法见 register_update_notify()，协程示例见 单线程创建多个异步任务。

async TqChan.send(item: Any) → None

异步发送数据到channel中

Args:

item (any): 待发送的对象

TqChan.send_nowait(item: Any) → None

尝试立即发送数据到channel中

Args:

item (any): 待发送的对象

Raises:

asyncio.QueueFull: 如果channel已满则会抛出 asyncio.QueueFull

async TqChan.recv() → Any

异步接收channel中的数据，如果channel中没有数据则一直等待

Returns:

any: 收到的数据，如果channel已被关闭则会立即收到None

TqChan.recv_nowait() → Any

尝试立即接收channel中的数据

Returns:

any: 收到的数据，如果channel已被关闭则会立即收到None

Raises:

asyncio.QueueFull: 如果channel中没有数据则会抛出 asyncio.QueueEmpty

TqChan.recv_latest(latest: Any) → Any

尝试立即接收channel中的最后一个数据

Args:

latest (any): 如果当前channel中没有数据或已关闭则返回该对象

Returns:

any: channel中的最后一个数据

async TqChan.close() → None

关闭channel

关闭后send将不起作用,recv在收完剩余数据后会立即返回None