Async convenience method to poll a ring buffer by name
(
self, name, thread_index=0, timeout=None, callback=None
)
| 316 | return ring_buffer.poll_for_data(thread_index, timeout, callback) |
| 317 | |
| 318 | async def poll_ring_buffer_async( |
| 319 | self, name, thread_index=0, timeout=None, callback=None |
| 320 | ): |
| 321 | """Async convenience method to poll a ring buffer by name""" |
| 322 | ring_buffer = self.get_ring_buffer(name) |
| 323 | return await ring_buffer.poll_for_data_async(thread_index, timeout, callback) |
| 324 | |
| 325 | def get_ring_buffer_schema(self, name, thread_index=0): |
| 326 | """Get schema from a ring buffer by name""" |
nothing calls this directly
no test coverage detected