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..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",
@@ -12,7 +12,7 @@
     "url": "git+https://github.com/Reactive-Extensions/rx-node.git"
   },
   "dependencies": {
-    "rx": "*"
+    "rxjs": "^5.0.0-beta.10"
   },
   "devDependencies": {
     "tape": "^4.4.0",