fix: fix ping!!

daviddias · daviddias · commit 05b0c5eaaaac · 2018-10-31T10:14:14.000Z
diff --git a/src/core/components/ping-pull-stream.js b/src/core/components/ping-pull-stream.js
@@ -27,7 +27,7 @@ module.exports = function pingPullStream (self) {
       if (err) {
         log.error(err)
         source.push(getPacket({ success: false, text: err.toString() }))
-        source.end(err)
+        source.end()
       }
     })
 
diff --git a/src/http/api/resources/ping.js b/src/http/api/resources/ping.js
@@ -43,6 +43,6 @@ exports.get = {
     const responseStream = toStream.source(source)
     const stream2 = new PassThrough()
     pump(responseStream, stream2)
-    return reply(stream2).type('application/json').header('X-Chunked-Output', '1')
+    reply(stream2).type('application/json').header('X-Chunked-Output', '1')
   }
 }

Original file line number	Diff line number	Diff line change
`@@ -27,7 +27,7 @@ module.exports = function pingPullStream (self) {`
`27`	`27`	`if (err) {`
`28`	`28`	`log.error(err)`
`29`	`29`	`source.push(getPacket({ success: false, text: err.toString() }))`
`30`		`- source.end(err)`
	`30`	`+ source.end()`
`31`	`31`	`}`
`32`	`32`	`})`
`33`	`33`
Original file line number	Diff line number	Diff line change
`@@ -43,6 +43,6 @@ exports.get = {`
`43`	`43`	`const responseStream = toStream.source(source)`
`44`	`44`	`const stream2 = new PassThrough()`
`45`	`45`	`pump(responseStream, stream2)`
`46`		`- return reply(stream2).type('application/json').header('X-Chunked-Output', '1')`
	`46`	`+ reply(stream2).type('application/json').header('X-Chunked-Output', '1')`
`47`	`47`	`}`
`48`	`48`	`}`