userver: userver/ugrpc/impl/queue_runner.hpp Source File
Loading...
Searching...
No Matches
queue_runner.hpp
1#pragma once
2
3#include <grpcpp/completion_queue.h>
4
5#include <userver/engine/single_use_event.hpp>
6
7USERVER_NAMESPACE_BEGIN
8
9namespace ugrpc::impl {
10
11class QueueRunner final {
12 public:
13 explicit QueueRunner(grpc::CompletionQueue& queue);
14 ~QueueRunner();
15
16 private:
17 grpc::CompletionQueue& queue_;
18 engine::SingleUseEvent completion_;
19};
20
21} // namespace ugrpc::impl
22
23USERVER_NAMESPACE_END