| 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 |