caproto.curio.server.UniversalQueue

class caproto.curio.server.UniversalQueue(*, maxsize=0, withfd=False)

Methods

async_get()
async_put(value)
empty()
fileno()
full()
get()
join()
join_sync()
put(value)
qsize()
task_done()
task_done_sync()