12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152 |
- // Copyright 2021 The Chromium 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 "ash/quick_pair/message_stream/fake_message_stream_lookup.h"
- namespace ash {
- namespace quick_pair {
- FakeMessageStreamLookup::FakeMessageStreamLookup() = default;
- FakeMessageStreamLookup::~FakeMessageStreamLookup() = default;
- MessageStream* FakeMessageStreamLookup::GetMessageStream(
- const std::string& device_address) {
- auto it = message_streams_.find(device_address);
- if (it == message_streams_.end())
- return nullptr;
- return it->second;
- }
- void FakeMessageStreamLookup::AddObserver(Observer* observer) {
- observers_.AddObserver(observer);
- }
- void FakeMessageStreamLookup::RemoveObserver(Observer* observer) {
- observers_.RemoveObserver(observer);
- }
- void FakeMessageStreamLookup::NotifyMessageStreamConnected(
- const std::string& device_address,
- MessageStream* message_stream) {
- for (auto& observer : observers_)
- observer.OnMessageStreamConnected(device_address, message_stream);
- }
- void FakeMessageStreamLookup::AddMessageStream(
- const std::string& device_address,
- MessageStream* message_stream) {
- DCHECK(message_streams_.find(device_address) == message_streams_.end());
- message_streams_[device_address] = message_stream;
- }
- void FakeMessageStreamLookup::RemoveMessageStream(
- const std::string& device_address) {
- message_streams_.erase(device_address);
- }
- } // namespace quick_pair
- } // namespace ash
|