diff --git a/sharing/fake_nearby_connection.cc b/sharing/fake_nearby_connection.cc index 09c34b15..71765b7f 100644 --- a/sharing/fake_nearby_connection.cc +++ b/sharing/fake_nearby_connection.cc @@ -86,6 +86,16 @@ void FakeNearbyConnection::SetDisconnectionListener( void FakeNearbyConnection::AppendReadableData(std::vector bytes) { NL_DCHECK(!closed_); + if (task_runner_) { + task_runner_->PostTask([this, bytes = std::move(bytes)]() { + { + absl::MutexLock lock(&read_mutex_); + read_data_.push(std::move(bytes)); + } + MaybeRunCallback(); + }); + return; + } { absl::MutexLock lock(&read_mutex_); read_data_.push(std::move(bytes));