| // Copyright 2013 The Flutter 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 "task_runner_adapter.h" |
| |
| #include <lib/async/cpp/task.h> |
| #include <lib/async/default.h> |
| #include <lib/zx/time.h> |
| |
| #include "flutter/fml/message_loop_impl.h" |
| |
| namespace flutter_runner { |
| |
| class CompatTaskRunner : public fml::TaskRunner { |
| public: |
| CompatTaskRunner(async_dispatcher_t* dispatcher) |
| : fml::TaskRunner(nullptr), forwarding_target_(dispatcher) { |
| FML_DCHECK(forwarding_target_); |
| } |
| |
| void PostTask(const fml::closure& task) override { |
| async::PostTask(forwarding_target_, task); |
| } |
| |
| void PostTaskForTime(const fml::closure& task, |
| fml::TimePoint target_time) override { |
| async::PostTaskForTime( |
| forwarding_target_, task, |
| zx::time(target_time.ToEpochDelta().ToNanoseconds())); |
| } |
| |
| void PostDelayedTask(const fml::closure& task, |
| fml::TimeDelta delay) override { |
| async::PostDelayedTask(forwarding_target_, task, |
| zx::duration(delay.ToNanoseconds())); |
| } |
| |
| bool RunsTasksOnCurrentThread() override { |
| return forwarding_target_ == async_get_default_dispatcher(); |
| } |
| |
| private: |
| async_dispatcher_t* 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( |
| async_dispatcher_t* dispatcher) { |
| return fml::MakeRefCounted<CompatTaskRunner>(dispatcher); |
| } |
| |
| } // namespace flutter_runner |