Skip to content
This repository was archived by the owner on Mar 10, 2020. It is now read-only.

Commit 4dd718b

Browse files
committed
Use Stream.Readable instead of Stream directly
1 parent 48a5cd7 commit 4dd718b

File tree

1 file changed

+6
-5
lines changed

1 file changed

+6
-5
lines changed

src/api/pubsub.js

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -2,9 +2,10 @@
22

33
const promisify = require('promisify-es6')
44
const bs58 = require('bs58')
5-
var Base64 = require('js-base64').Base64
6-
var Stream = require('stream')
7-
var http = require('http')
5+
const Base64 = require('js-base64').Base64
6+
const Stream = require('stream')
7+
const Readable = Stream.Readable
8+
const http = require('http')
89

910
let activeSubscriptions = []
1011

@@ -39,8 +40,8 @@ module.exports = (send, config) => {
3940
options = {}
4041
}
4142

42-
var rs = new Stream()
43-
rs.readable = true
43+
var rs = new Readable({objectMode: true})
44+
rs._read = () => {}
4445

4546
if (!subscriptionExists(activeSubscriptions, topic)) {
4647
activeSubscriptions = addSubscription(activeSubscriptions, topic)

0 commit comments

Comments
 (0)