Merge branch 'naruaway-auto-scope-nested-patch' into auto-scope

src/http-driver.js

@@ -101,13 +101,6 @@ function normalizeRequestOptions(reqOptions) {
   }
 }
 
-function isolateSource(response$$, scope) {
-  return response$$.filter(res$ =>
-    Array.isArray(res$.request._namespace) &&
-    res$.request._namespace.indexOf(scope) !== -1
-  )
-}
-
 function isolateSink(request$, scope) {
   return request$.map(req => {
     if (typeof req === `string`) {
@@ -119,6 +112,16 @@ function isolateSink(request$, scope) {
   })
 }
 
+function isolateSource(response$$, scope) {
+  let isolatedResponse$$ = response$$.filter(res$ =>
+    Array.isArray(res$.request._namespace) &&
+    res$.request._namespace.indexOf(scope) !== -1
+  )
+  isolatedResponse$$.isolateSource = isolateSource
+  isolatedResponse$$.isolateSink = isolateSink
+  return isolatedResponse$$
+}
+
 function makeHTTPDriver({eager = false} = {eager: false}) {
   return function httpDriver(request$) {
     let response$$ = request$

test/common.js

@@ -171,6 +171,29 @@ function run(uri) {
   });
 
   describe('isolateSource and isolateSink', function () {
+    it('should exist on the HTTP Source (response$$)', function(done) {
+      var httpDriver = makeHTTPDriver();
+      var request$ = new Rx.Subject();
+      var response$$ = httpDriver(request$);
+
+      assert.strictEqual(typeof response$$.isolateSource, 'function');
+      assert.strictEqual(typeof response$$.isolateSink, 'function');
+      done();
+    });
+
+    it('should exist on a scoped HTTP Source (response$$)', function(done) {
+      var httpDriver = makeHTTPDriver();
+      var request$ = new Rx.Subject();
+      var response$$ = httpDriver(request$);
+
+      var scopedRequest$ = response$$.isolateSink(request$, 'foo');
+      var scopedResponse$$ = response$$.isolateSource(response$$, 'foo');
+
+      assert.strictEqual(typeof scopedResponse$$.isolateSource, 'function');
+      assert.strictEqual(typeof scopedResponse$$.isolateSink, 'function');
+      done();
+    });
+
     it('should hide responses from outside the scope',
       function(done) {
         var httpDriver = makeHTTPDriver();