diff --git a/index.js b/index.js
index b3da8ac..37ad302 100644
--- a/index.js
+++ b/index.js
@@ -1,4 +1,8 @@
 'use strict';
+
+// Require "rxjs" for any-observable (see #127)
+require('any-observable/register')(require.resolve('rxjs'));
+
 const pMap = require('p-map');
 const Task = require('./lib/task');
 const TaskWrapper = require('./lib/task-wrapper');
diff --git a/package.json b/package.json
index 19129c8..20b444a 100644
--- a/package.json
+++ b/package.json
@@ -39,6 +39,7 @@
 	],
 	"dependencies": {
 		"@samverschueren/stream-to-observable": "^0.3.0",
+		"any-observable": "^0.3.0",
 		"is-observable": "^1.1.0",
 		"is-promise": "^2.1.0",
 		"is-stream": "^1.1.0",