OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 // Tests launched by extensions/renderer/api/serial/data_receiver_unittest.cc | 5 // Tests launched by extensions/renderer/api/serial/data_receiver_unittest.cc |
6 | 6 |
7 var test = require('test').binding; | 7 var test = require('test').binding; |
8 var unittestBindings = require('test_environment_specific_bindings'); | 8 var unittestBindings = require('test_environment_specific_bindings'); |
9 | 9 |
10 var BUFFER_SIZE = 10; | 10 var BUFFER_SIZE = 10; |
11 var FATAL_ERROR = 2; | 11 var FATAL_ERROR = 2; |
12 | 12 |
13 // Returns a promise to a newly created DataReceiver. | 13 // Returns a promise to a newly created DataReceiver. |
14 function createReceiver() { | 14 function createReceiver() { |
15 return Promise.all([ | 15 return Promise.all([ |
| 16 requireAsync('content/public/renderer/service_provider'), |
16 requireAsync('data_receiver'), | 17 requireAsync('data_receiver'), |
17 requireAsync('device/serial/data_receiver_test_factory'), | 18 requireAsync('device/serial/data_stream.mojom'), |
18 ]).then(function(modules) { | 19 ]).then(function(modules) { |
19 var dataReceiver = modules[0]; | 20 var serviceProvider = modules[0]; |
20 var factory = modules[1]; | 21 var dataReceiver = modules[1]; |
21 var receiver = factory.create(); | 22 var dataStream = modules[2]; |
22 return new dataReceiver.DataReceiver(receiver.source, receiver.client, | 23 return new dataReceiver.DataReceiver( |
23 BUFFER_SIZE, FATAL_ERROR); | 24 serviceProvider.connectToService(dataStream.DataSource.name), |
| 25 BUFFER_SIZE, |
| 26 FATAL_ERROR); |
24 }); | 27 }); |
25 } | 28 } |
26 | 29 |
27 // Returns a promise that will resolve to |receiver| when it has received an | 30 // Returns a promise that will resolve to |receiver| when it has received an |
28 // error from its DataSource. | 31 // error from its DataSource. |
29 function waitForReceiveError(receiver) { | 32 function waitForReceiveError(receiver) { |
30 return new Promise(function(resolve, reject) { | 33 return new Promise(function(resolve, reject) { |
31 var onError = receiver.onError; | 34 var onError = receiver.onError; |
32 receiver.onError = function() { | 35 receiver.onError = function() { |
33 $Function.apply(onError, receiver, arguments); | 36 $Function.apply(onError, receiver, arguments); |
(...skipping 132 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
166 } | 169 } |
167 | 170 |
168 createReceiver() | 171 createReceiver() |
169 .then(closeReceiver) | 172 .then(closeReceiver) |
170 .then(serializeRoundTrip) | 173 .then(serializeRoundTrip) |
171 .then(receiveAfterClose) | 174 .then(receiveAfterClose) |
172 .then(test.succeed, test.fail); | 175 .then(test.succeed, test.fail); |
173 }, | 176 }, |
174 | 177 |
175 ], test.runTests, exports); | 178 ], test.runTests, exports); |
OLD | NEW |