| 312 | } |
| 313 | template<class P, typename ...Args> |
| 314 | void ChannelInternal_::EnqueuePacketAsync(Args&& ...args) |
| 315 | { |
| 316 | Queue_(this).enqueue(std::make_shared<P>(std::forward<Args>(args)...)); |
| 317 | } |
| 318 | bool ChannelInternal_::IsWorkerThread() const noexcept |
| 319 | { |
| 320 | return workerTid_.load() == GetCurrentThreadId(); |
nothing calls this directly
no outgoing calls
no test coverage detected