: thread_factory_(thread_factory), store_(store), time_system_(time_system),

      file_system_(file_system), random_generator_(random_generator), bootstrap_(bootstrap),

      process_context_(process_context), watermark_factory_(std::move(watermark_factory)) {}

Event::DispatcherPtr Impl::allocateDispatcher(const std::string& name) {

  return std::make_unique<Event::DispatcherImpl>(name, *this, time_system_, watermark_factory_);

}

                         const Event::ScaledRangeTimerManagerFactory& scaled_timer_factory) {

  return std::make_unique<Event::DispatcherImpl>(name, *this, time_system_, scaled_timer_factory,

                                                 watermark_factory_);

}

                                              Buffer::WatermarkFactoryPtr&& factory) {

  return std::make_unique<Event::DispatcherImpl>(name, *this, time_system_, std::move(factory));

}