| // Copyright 2023 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 <lib/async/cpp/sequence_checker.h> |
| |
| #include <sdk/lib/async_patterns/cpp/internal/receiver_base.h> |
| |
| namespace async_patterns::internal { |
| |
| namespace { |
| |
| constexpr const char kReceiverThreadingError[] = "|async_patterns::Receiver| is thread-unsafe."; |
| |
| } |
| |
| ReceiverBase::~ReceiverBase() { task_queue_->Stop(); } |
| |
| async_dispatcher_t* ReceiverBase::dispatcher() const { return dispatcher_; } |
| |
| ReceiverBase::ReceiverBase(async_dispatcher_t* dispatcher) |
| : dispatcher_(dispatcher), |
| task_queue_(TaskQueue::Create(dispatcher, kReceiverThreadingError)) {} |
| |
| } // namespace async_patterns::internal |
