Chromium Code Reviews| Index: components/offline_pages/background/request_queue.cc |
| diff --git a/components/offline_pages/background/request_queue.cc b/components/offline_pages/background/request_queue.cc |
| index 80898030c541959cdcdc07ee4a64b00fac2f85b6..2894db3dd2b17efcc25f779705ea5605d6d370a0 100644 |
| --- a/components/offline_pages/background/request_queue.cc |
| +++ b/components/offline_pages/background/request_queue.cc |
| @@ -7,6 +7,7 @@ |
| #include "base/bind.h" |
| #include "base/location.h" |
| #include "base/threading/thread_task_runner_handle.h" |
| +#include "components/offline_pages/background/change_requests_state_task.h" |
| #include "components/offline_pages/background/request_queue_store.h" |
| #include "components/offline_pages/background/save_page_request.h" |
| @@ -73,13 +74,6 @@ void UpdateRequestsDone(const RequestQueue::UpdateRequestCallback& callback, |
| } |
| // Handles updating multiple requests at the same time. |
|
Pete Williamson
2016/09/27 23:49:56
Comment can go too if you re removing the method.
fgorski
2016/09/28 22:39:07
Done.
|
| -void UpdateMultipleRequestsDone( |
| - const RequestQueue::UpdateMultipleRequestsCallback& callback, |
| - const RequestQueue::UpdateMultipleRequestResults& results, |
| - std::vector<std::unique_ptr<SavePageRequest>> requests) { |
| - callback.Run(results, std::move(requests)); |
| -} |
| - |
| // Completes the remove request call. |
| void RemoveRequestsDone( |
| const RequestQueue::RemoveRequestsCallback& callback, |
| @@ -165,9 +159,10 @@ void RequestQueue::RemoveRequests(const std::vector<int64_t>& request_ids, |
| void RequestQueue::ChangeRequestsState( |
| const std::vector<int64_t>& request_ids, |
| const SavePageRequest::RequestState new_state, |
| - const UpdateMultipleRequestsCallback& callback) { |
| - store_->ChangeRequestsState(request_ids, new_state, |
| - base::Bind(UpdateMultipleRequestsDone, callback)); |
| + const RequestQueue::UpdateCallback& callback) { |
| + std::unique_ptr<TaskQueue::Task> task(new ChangeRequestsStateTask( |
| + store_.get(), request_ids, new_state, callback)); |
| + task_queue_.AddTask(std::move(task)); |
| } |
| void RequestQueue::PurgeRequests(const PurgeRequestsCallback& callback) {} |