From 05d5561ccc76ae0c705f1ff72bb650154eb09450 Mon Sep 17 00:00:00 2001 From: Jonathan Dunlap Date: Sun, 24 Apr 2016 20:33:38 -0700 Subject: [PATCH 1/3] Rxjs5 changes --- index.js | 10 +++++----- package.json | 2 +- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/index.js b/index.js index ab46b0f..23848a2 100644 --- a/index.js +++ b/index.js @@ -1,4 +1,4 @@ -var Rx = require('rx'); +var Rx = require('rxjs/Rx'); // Add specific Node functions var EventEmitter = require('events').EventEmitter, Observable = Rx.Observable; @@ -57,15 +57,15 @@ module.exports = { return Observable.create(function (observer) { function dataHandler (data) { - observer.onNext(data); + observer.next(data); } function errorHandler (err) { - observer.onError(err); + observer.error(err); } function endHandler () { - observer.onCompleted(); + observer.complete(); } stream.addListener(dataEventName, dataHandler); @@ -79,7 +79,7 @@ module.exports = { stream.removeListener('error', errorHandler); stream.removeListener(finishEventName, endHandler); }; - }).publish().refCount(); + }).share(); //publish().refCount(); }, /** diff --git a/package.json b/package.json index 5729f57..d2991c5 100644 --- a/package.json +++ b/package.json @@ -12,7 +12,7 @@ "url": "git+https://github.com/Reactive-Extensions/rx-node.git" }, "dependencies": { - "rx": "*" + "rxjs": "^5.0.0-beta.6" }, "devDependencies": { "tape": "^4.4.0", From ea777916d02d8142667ccf9a0807fb8df15be677 Mon Sep 17 00:00:00 2001 From: jdunlap Date: Fri, 22 Jul 2016 18:15:22 -0700 Subject: [PATCH 2/3] rxjs5b10 bump --- package.json | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/package.json b/package.json index d2991c5..2ed4490 100644 --- a/package.json +++ b/package.json @@ -12,7 +12,7 @@ "url": "git+https://github.com/Reactive-Extensions/rx-node.git" }, "dependencies": { - "rxjs": "^5.0.0-beta.6" + "rxjs": "^5.0.0-beta.10" }, "devDependencies": { "tape": "^4.4.0", From 195a9f796802400540c6e0295b551a6d3a234667 Mon Sep 17 00:00:00 2001 From: jdunlap Date: Fri, 22 Jul 2016 18:15:54 -0700 Subject: [PATCH 3/3] 1.0.3 --- package.json | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/package.json b/package.json index 2ed4490..62af8fc 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "rx-node", - "version": "1.0.2", + "version": "1.0.3", "title": "Reactive Extensions for JavaScript (RxJS) Bindings for Node.js/io.js", "description": "RxJS Bindings for Node.js and io.js", "main": "index.js",