|
|
|
@ -24,6 +24,10 @@ class dist_sink : public base_sink<Mutex>
|
|
|
|
|
{
|
|
|
|
|
public:
|
|
|
|
|
dist_sink() = default;
|
|
|
|
|
explicit dist_sink(std::vector<std::shared_ptr<sink>> sinks)
|
|
|
|
|
: sinks_(sinks)
|
|
|
|
|
{}
|
|
|
|
|
|
|
|
|
|
dist_sink(const dist_sink &) = delete;
|
|
|
|
|
dist_sink &operator=(const dist_sink &) = delete;
|
|
|
|
|
|
|
|
|
|