Adds an observer for the request coordinator.

components/offline_pages/background/request_queue.cc

 // Copyright 2016 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 "components/offline_pages/background/request_queue.h"
 
 #include "base/bind.h"
 #include "base/location.h"
 #include "base/threading/thread_task_runner_handle.h"
 #include "components/offline_pages/background/request_queue_store.h"
@@ skipping 21 matching lines @@
                     const SavePageRequest& request,
                     RequestQueueStore::UpdateStatus status) {
   RequestQueue::AddRequestResult result =
       (status == RequestQueueStore::UpdateStatus::UPDATED)
           ? RequestQueue::AddRequestResult::SUCCESS
           : RequestQueue::AddRequestResult::STORE_FAILURE;
   callback.Run(result, request);
 }
 
 // Completes the update request call.
+// TODO(petewil): Move callers to the UpdateMultipleRequestDone callback
 void UpdateRequestDone(const RequestQueue::UpdateRequestCallback& callback,
                        RequestQueueStore::UpdateStatus status) {
   RequestQueue::UpdateRequestResult result =
       (status == RequestQueueStore::UpdateStatus::UPDATED)
           ? RequestQueue::UpdateRequestResult::SUCCESS
           : RequestQueue::UpdateRequestResult::STORE_FAILURE;
   callback.Run(result);
 }
 
+// Handles updating multiple requests at the same time.
+void UpdateMultipleRequestsDone(
+    const RequestQueue::UpdateMultipleRequestsCallback& callback,
+    const RequestQueue::UpdateMultipleRequestResults& results,
+    const std::vector<SavePageRequest>& requests) {
+  callback.Run(results, requests);
+}
 
 // Completes the remove request call.
 void RemoveRequestsDone(
     const RequestQueue::RemoveRequestsCallback& callback,
-    const RequestQueue::UpdateMultipleRequestResults& results) {
-  callback.Run(results);
+    const RequestQueue::UpdateMultipleRequestResults& results,
+    const std::vector<SavePageRequest>& requests) {
+  callback.Run(results, requests);
 }
 
 }  // namespace
 
 RequestQueue::RequestQueue(std::unique_ptr<RequestQueueStore> store)
     : store_(std::move(store)), weak_ptr_factory_(this) {}
 
 RequestQueue::~RequestQueue() {}
 
 void RequestQueue::GetRequests(const GetRequestsCallback& callback) {
@@ skipping 59 matching lines @@
 }
 
 void RequestQueue::RemoveRequests(const std::vector<int64_t>& request_ids,
                                   const RemoveRequestsCallback& callback) {
   store_->RemoveRequests(request_ids, base::Bind(RemoveRequestsDone, callback));
 }
 
 void RequestQueue::ChangeRequestsState(
     const std::vector<int64_t>& request_ids,
     const SavePageRequest::RequestState new_state,
-    const UpdateRequestCallback& callback) {
+    const UpdateMultipleRequestsCallback& callback) {
   store_->ChangeRequestsState(request_ids, new_state,
-                              base::Bind(UpdateRequestDone, callback));
+                              base::Bind(UpdateMultipleRequestsDone, callback));
 }
 
 void RequestQueue::PurgeRequests(const PurgeRequestsCallback& callback) {}
 
 }  // namespace offline_pages