| 565 | } |
| 566 | |
| 567 | void ChannelImpl::sync_impl() { |
| 568 | m_worker.wait_all_task_finish(); |
| 569 | MGB_LOCK_GUARD(m_mutex); |
| 570 | check_worker_exc_unsafe(); |
| 571 | } |
| 572 | |
| 573 | void ChannelImpl::close() { |
| 574 | MGB_LOCK_GUARD(m_spin); |
nothing calls this directly
no test coverage detected