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'), | |
17 requireAsync('data_receiver'), | 16 requireAsync('data_receiver'), |
18 requireAsync('device/serial/data_stream.mojom'), | 17 requireAsync('device/serial/data_receiver_test_factory'), |
19 ]).then(function(modules) { | 18 ]).then(function(modules) { |
20 var serviceProvider = modules[0]; | 19 var dataReceiver = modules[0]; |
21 var dataReceiver = modules[1]; | 20 var factory = modules[1]; |
22 var dataStream = modules[2]; | 21 var receiver = factory.create(); |
23 return new dataReceiver.DataReceiver( | 22 return new dataReceiver.DataReceiver(receiver.source, receiver.client, |
24 serviceProvider.connectToService(dataStream.DataSource.name), | 23 BUFFER_SIZE, FATAL_ERROR); |
25 BUFFER_SIZE, | |
26 FATAL_ERROR); | |
27 }); | 24 }); |
28 } | 25 } |
29 | 26 |
30 // Returns a promise that will resolve to |receiver| when it has received an | 27 // Returns a promise that will resolve to |receiver| when it has received an |
31 // error from its DataSource. | 28 // error from its DataSource. |
32 function waitForReceiveError(receiver) { | 29 function waitForReceiveError(receiver) { |
33 return new Promise(function(resolve, reject) { | 30 return new Promise(function(resolve, reject) { |
34 var onError = receiver.onError; | 31 var onError = receiver.onError; |
35 receiver.onError = function() { | 32 receiver.onError = function() { |
36 $Function.apply(onError, receiver, arguments); | 33 $Function.apply(onError, receiver, arguments); |
(...skipping 132 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
169 } | 166 } |
170 | 167 |
171 createReceiver() | 168 createReceiver() |
172 .then(closeReceiver) | 169 .then(closeReceiver) |
173 .then(serializeRoundTrip) | 170 .then(serializeRoundTrip) |
174 .then(receiveAfterClose) | 171 .then(receiveAfterClose) |
175 .then(test.succeed, test.fail); | 172 .then(test.succeed, test.fail); |
176 }, | 173 }, |
177 | 174 |
178 ], test.runTests, exports); | 175 ], test.runTests, exports); |
OLD | NEW |