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

Side by Side Diff: examples/dart/wget.dart

Issue 816113004: Dart: Adds a content handler and a test. (Closed) Base URL: git@github.com:domokit/mojo.git@master
Patch Set: Address comments Created 5 years, 11 months 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
« no previous file with comments | « no previous file | mojo/BUILD.gn » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
(Empty)
1 #!mojo mojo:dart_content_handler
2
3 // Copyright 2014 The Chromium Authors. All rights reserved.
4 // Use of this source code is governed by a BSD-style license that can be
5 // found in the LICENSE file.
6
7 import 'dart:async';
8 import 'dart:mojo_application';
9 import 'dart:mojo_bindings';
10 import 'dart:mojo_core';
11 import 'dart:typed_data';
12
13 import 'package:mojo/services/network/public/interfaces/network_service.mojom.da rt';
14 import 'package:mojo/services/network/public/interfaces/url_loader.mojom.dart';
15
16 class WGet extends Application {
17 NetworkServiceClient _networkServiceClient;
18 UrlLoaderClient _urlLoaderClient;
19
20 WGet.fromHandle(MojoHandle shellHandle) : super.fromHandle(shellHandle);
21
22 void initialize(List<String> args) {
23 run(args);
24 }
25
26 run(List<String> args) async {
27 if (args.length != 2) {
28 throw "Expected URL argument";
29 }
30
31 ByteData bodyData = await _getUrl(args[1]);
32 print("read ${bodyData.lengthInBytes} bytes");
33
34 _closeClients();
35 close();
36 }
37
38 Future<ByteData> _getUrl(String url) async {
39 _initClientsIfNeeded();
40
41 var urlRequest = new UrlRequest()
42 ..url = url
43 ..autoFollowRedirects = true;
44
45 var urlResponse = await _urlLoaderClient.callStart(urlRequest);
46 print("url => ${urlResponse.response.url}");
47 print("status_line => ${urlResponse.response.statusLine}");
48 print("mime_type => ${urlResponse.response.mimeType}");
49
50 return DataPipeDrainer.drainHandle(urlResponse.response.body);
51 }
52
53 void _initClientsIfNeeded() {
54 if (_networkServiceClient == null) {
55 var networkServiceClientEndpoint = connectToService(
56 "mojo:network_service", NetworkServiceInterface.name);
57 _networkServiceClient =
58 new NetworkServiceClient(networkServiceClientEndpoint);
59 }
60 if (_urlLoaderClient == null) {
61 _urlLoaderClient = new UrlLoaderClient.unbound();
62 _networkServiceClient.callCreateUrlLoader(_urlLoaderClient);
63 }
64 }
65
66 void _closeClients() {
67 _urlLoaderClient.close();
68 _networkServiceClient.close();
69 _urlLoaderClient = null;
70 _networkServiceClient = null;
71 }
72 }
73
74 main(List args) {
75 MojoHandle shellHandle = new MojoHandle(args[0]);
76 String url = args[1];
77 var wget = new WGet.fromHandle(shellHandle);
78 wget.listen();
79 }
OLDNEW
« no previous file with comments | « no previous file | mojo/BUILD.gn » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698