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