mirror of
https://github.com/openstf/stf
synced 2025-10-05 10:39:25 +02:00
Properly require the split module.
This commit is contained in:
parent
bc162676e3
commit
f1c4e68ef7
1 changed files with 5 additions and 4 deletions
|
@ -8,6 +8,7 @@ var adbkit = require('adbkit')
|
||||||
var monkey = require('adbkit-monkey')
|
var monkey = require('adbkit-monkey')
|
||||||
var request = Promise.promisifyAll(require('request'))
|
var request = Promise.promisifyAll(require('request'))
|
||||||
var httpProxy = require('http-proxy')
|
var httpProxy = require('http-proxy')
|
||||||
|
var split = require('split')
|
||||||
|
|
||||||
var logger = require('../util/logger')
|
var logger = require('../util/logger')
|
||||||
var wire = require('../wire')
|
var wire = require('../wire')
|
||||||
|
@ -150,7 +151,7 @@ module.exports = function(options) {
|
||||||
])
|
])
|
||||||
.then(function(out) {
|
.then(function(out) {
|
||||||
vitals.register('device:remote:http:shell', out)
|
vitals.register('device:remote:http:shell', out)
|
||||||
out.pipe(require('split')())
|
out.pipe(split())
|
||||||
.on('data', function(chunk) {
|
.on('data', function(chunk) {
|
||||||
log.info(chunk)
|
log.info(chunk)
|
||||||
})
|
})
|
||||||
|
@ -241,7 +242,7 @@ module.exports = function(options) {
|
||||||
))
|
))
|
||||||
.then(function(out) {
|
.then(function(out) {
|
||||||
vitals.register('device:remote:monkey:shell', out)
|
vitals.register('device:remote:monkey:shell', out)
|
||||||
out.pipe(require('split')())
|
out.pipe(split())
|
||||||
.on('data', function(chunk) {
|
.on('data', function(chunk) {
|
||||||
log.info(chunk)
|
log.info(chunk)
|
||||||
})
|
})
|
||||||
|
@ -271,7 +272,7 @@ module.exports = function(options) {
|
||||||
])
|
])
|
||||||
.then(function(out) {
|
.then(function(out) {
|
||||||
vitals.register('device:remote:input:shell', out)
|
vitals.register('device:remote:input:shell', out)
|
||||||
out.pipe(require('split')())
|
out.pipe(split())
|
||||||
.on('data', function(chunk) {
|
.on('data', function(chunk) {
|
||||||
log.info(chunk)
|
log.info(chunk)
|
||||||
})
|
})
|
||||||
|
@ -301,7 +302,7 @@ module.exports = function(options) {
|
||||||
])
|
])
|
||||||
.then(function(out) {
|
.then(function(out) {
|
||||||
vitals.register('device:remote:stats:shell', out)
|
vitals.register('device:remote:stats:shell', out)
|
||||||
out.pipe(require('split')())
|
out.pipe(split())
|
||||||
.on('data', function(chunk) {
|
.on('data', function(chunk) {
|
||||||
log.info(chunk)
|
log.info(chunk)
|
||||||
})
|
})
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue