var dataReceiver = modules[1];
var dataStream = modules[2];
return new dataReceiver.DataReceiver(
- serviceProvider.connectToService(dataStream.DataSourceProxy.NAME_),
+ serviceProvider.connectToService(dataStream.DataSource.name),
BUFFER_SIZE,
FATAL_ERROR);
});
.then(test.succeed, test.fail);
},
- function testSourceShutdown() {
- createReceiver()
- .then(receiveAndCheckError(FATAL_ERROR))
- .then(closeReceiver)
- .then(test.succeed, test.fail);
- },
-
], test.runTests, exports);