| // Copyright 2018 The Fuchsia Authors. All rights reserved. |
| // Use of this source code is governed by a BSD-style license that can be |
| // found in the LICENSE file. |
| |
| #include "topaz/runtime/flutter_runner/task_runner_adapter.h" |
| |
| #include "flutter/fml/message_loop_impl.h" |
| |
| namespace flutter { |
| |
| class CompatTaskRunner : public fml::TaskRunner { |
| public: |
| CompatTaskRunner(fxl::RefPtr<fxl::TaskRunner> runner) |
| : fml::TaskRunner(nullptr), forwarding_target_(std::move(runner)) { |
| FML_DCHECK(forwarding_target_); |
| } |
| |
| void PostTask(fml::closure task) override { |
| forwarding_target_->PostTask(std::move(task)); |
| } |
| |
| void PostTaskForTime(fml::closure task, fml::TimePoint target_time) override { |
| forwarding_target_->PostTaskForTime( |
| std::move(task), |
| fxl::TimePoint::FromEpochDelta(fxl::TimeDelta::FromNanoseconds( |
| target_time.ToEpochDelta().ToNanoseconds()))); |
| } |
| |
| void PostDelayedTask(fml::closure task, fml::TimeDelta delay) override { |
| forwarding_target_->PostDelayedTask( |
| std::move(task), |
| fxl::TimeDelta::FromNanoseconds(delay.ToNanoseconds())); |
| } |
| |
| bool RunsTasksOnCurrentThread() override { |
| return forwarding_target_->RunsTasksOnCurrentThread(); |
| } |
| |
| private: |
| fxl::RefPtr<fxl::TaskRunner> forwarding_target_; |
| |
| FML_DISALLOW_COPY_AND_ASSIGN(CompatTaskRunner); |
| FML_FRIEND_MAKE_REF_COUNTED(CompatTaskRunner); |
| FML_FRIEND_REF_COUNTED_THREAD_SAFE(CompatTaskRunner); |
| }; |
| |
| fml::RefPtr<fml::TaskRunner> CreateFMLTaskRunner( |
| fxl::RefPtr<fxl::TaskRunner> runner) { |
| return fml::MakeRefCounted<CompatTaskRunner>(std::move(runner)); |
| } |
| |
| } // namespace flutter |