Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(203)

Side by Side Diff: content/child/url_response_body_consumer.h

Issue 2459483002: [Mojo-Loading] Dispatch body data after response is received (Closed)
Patch Set: fix Created 4 years, 1 month ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 // Copyright 2016 The Chromium Authors. All rights reserved. 1 // Copyright 2016 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #ifndef CONTENT_CHILD_URL_RESPONSE_BODY_CONSUMER_H_ 5 #ifndef CONTENT_CHILD_URL_RESPONSE_BODY_CONSUMER_H_
6 #define CONTENT_CHILD_URL_RESPONSE_BODY_CONSUMER_H_ 6 #define CONTENT_CHILD_URL_RESPONSE_BODY_CONSUMER_H_
7 7
8 #include <stddef.h> 8 #include <stddef.h>
9 #include <stdint.h> 9 #include <stdint.h>
10 10
(...skipping 19 matching lines...) Expand all
30 class CONTENT_EXPORT URLResponseBodyConsumer final 30 class CONTENT_EXPORT URLResponseBodyConsumer final
31 : public base::RefCounted<URLResponseBodyConsumer>, 31 : public base::RefCounted<URLResponseBodyConsumer>,
32 public base::SupportsWeakPtr<URLResponseBodyConsumer> { 32 public base::SupportsWeakPtr<URLResponseBodyConsumer> {
33 public: 33 public:
34 URLResponseBodyConsumer( 34 URLResponseBodyConsumer(
35 int request_id, 35 int request_id,
36 ResourceDispatcher* resource_dispatcher, 36 ResourceDispatcher* resource_dispatcher,
37 mojo::ScopedDataPipeConsumerHandle handle, 37 mojo::ScopedDataPipeConsumerHandle handle,
38 scoped_refptr<base::SingleThreadTaskRunner> task_runner); 38 scoped_refptr<base::SingleThreadTaskRunner> task_runner);
39 39
40 // Starts watching the handle.
41 void Start(base::SingleThreadTaskRunner* task_runner);
42
40 // Sets the completion status. The completion status is dispatched to the 43 // Sets the completion status. The completion status is dispatched to the
41 // ResourceDispatcher when the both following conditions hold: 44 // ResourceDispatcher when the both following conditions hold:
42 // 1) This function has been called and the completion status is set, and 45 // 1) This function has been called and the completion status is set, and
43 // 2) All data is read from the handle. 46 // 2) All data is read from the handle.
44 void OnComplete(const ResourceRequestCompletionStatus& status); 47 void OnComplete(const ResourceRequestCompletionStatus& status);
45 48
46 // Cancels watching the handle and dispatches an error to the 49 // Cancels watching the handle and dispatches an error to the
47 // ResourceDispatcher. This function does nothing if the reading is already 50 // ResourceDispatcher. This function does nothing if the reading is already
48 // cancelled or done. 51 // cancelled or done.
49 void Cancel(); 52 void Cancel();
(...skipping 17 matching lines...) Expand all
67 bool has_received_completion_ = false; 70 bool has_received_completion_ = false;
68 bool has_been_cancelled_ = false; 71 bool has_been_cancelled_ = false;
69 bool has_seen_end_of_data_; 72 bool has_seen_end_of_data_;
70 73
71 DISALLOW_COPY_AND_ASSIGN(URLResponseBodyConsumer); 74 DISALLOW_COPY_AND_ASSIGN(URLResponseBodyConsumer);
72 }; 75 };
73 76
74 } // namespace content 77 } // namespace content
75 78
76 #endif // CONTENT_CHILD_URL_RESPONSE_BODY_CONSUMER_H_ 79 #endif // CONTENT_CHILD_URL_RESPONSE_BODY_CONSUMER_H_
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698