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('content/public/renderer/service_provider'), |
17 requireAsync('data_receiver'), | 17 requireAsync('data_receiver'), |
18 requireAsync('device/serial/data_stream.mojom'), | 18 requireAsync('device/serial/data_stream.mojom'), |
19 ]).then(function(modules) { | 19 ]).then(function(modules) { |
20 var serviceProvider = modules[0]; | 20 var serviceProvider = modules[0]; |
21 var dataReceiver = modules[1]; | 21 var dataReceiver = modules[1]; |
22 var dataStream = modules[2]; | 22 var dataStream = modules[2]; |
23 return new dataReceiver.DataReceiver( | 23 return new dataReceiver.DataReceiver( |
24 serviceProvider.connectToService(dataStream.DataSourceProxy.NAME_), | 24 serviceProvider.connectToService(dataStream.DataSource.name), |
25 BUFFER_SIZE, | 25 BUFFER_SIZE, |
26 FATAL_ERROR); | 26 FATAL_ERROR); |
27 }); | 27 }); |
28 } | 28 } |
29 | 29 |
30 // 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 |
31 // error from its DataSource. | 31 // error from its DataSource. |
32 function waitForReceiveError(receiver) { | 32 function waitForReceiveError(receiver) { |
33 return new Promise(function(resolve, reject) { | 33 return new Promise(function(resolve, reject) { |
34 var onError = receiver.onError; | 34 var onError = receiver.onError; |
(...skipping 141 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
176 }, | 176 }, |
177 | 177 |
178 function testSourceShutdown() { | 178 function testSourceShutdown() { |
179 createReceiver() | 179 createReceiver() |
180 .then(receiveAndCheckError(FATAL_ERROR)) | 180 .then(receiveAndCheckError(FATAL_ERROR)) |
181 .then(closeReceiver) | 181 .then(closeReceiver) |
182 .then(test.succeed, test.fail); | 182 .then(test.succeed, test.fail); |
183 }, | 183 }, |
184 | 184 |
185 ], test.runTests, exports); | 185 ], test.runTests, exports); |
OLD | NEW |