Updating docs for zip/combineLatest

Author: mattpodwysocki

doc/api/core/operators/combinelatest.md

@@ -12,6 +12,36 @@ Merges the specified observable sequences into one observable sequence by using
 
 #### Example
 ```js
+/* Have staggering intervals */
+var source1 = Rx.Observable.interval(100)
+  .map(function (i) { return 'First: ' + i; });
+
+var source2 = Rx.Observable.interval(150)
+  .map(function (i) { return 'Second: ' + i; });
+
+// Combine latest of source1 and source2 whenever either gives a value with a selector
+var source = Rx.Observable.combineLatest(
+    source1,
+    source2
+  ).take(4);
+
+var subscription = source.subscribe(
+  function (x) {
+    console.log('Next: %s', x);
+  },
+  function (err) {
+    console.log('Error: %s', err);
+  },
+  function () {
+    console.log('Completed');
+  });
+
+// => Next: First: 0,Second: 0
+// => Next: First: 1,Second: 0
+// => Next: First: 1,Second: 1
+// => Next: First: 2,Second: 1
+// => Completed
+
 /* Have staggering intervals */
 var source1 = Rx.Observable.interval(100)
   .map(function (i) { return 'First: ' + i; });
@@ -27,15 +57,15 @@ var source = Rx.Observable.combineLatest(
   ).take(4);
 
 var subscription = source.subscribe(
-    function (x) {
-      console.log('Next: %s', x);
-    },
-    function (err) {
-      console.log('Error: %s', err);
-    },
-    function () {
-      console.log('Completed');
-    });
+  function (x) {
+    console.log('Next: %s', x);
+  },
+  function (err) {
+    console.log('Error: %s', err);
+  },
+  function () {
+    console.log('Completed');
+  });
 
 // => Next: First: 0, Second: 0
 // => Next: First: 1, Second: 0

doc/api/core/operators/combinelatestproto.md

@@ -12,6 +12,35 @@ Merges the specified observable sequences into one observable sequence by using
 
 #### Example
 ```js
+/* Have staggering intervals */
+var source1 = Rx.Observable.interval(100)
+  .map(function (i) { return 'First: ' + i; });
+
+var source2 = Rx.Observable.interval(150)
+  .map(function (i) { return 'Second: ' + i; });
+
+// Combine latest of source1 and source2 whenever either gives a value with selector
+var source = source1.combineLatest(
+    source2
+  ).take(4);
+
+var subscription = source.subscribe(
+  function (x) {
+    console.log('Next: %s', x);
+  },
+  function (err) {
+    console.log('Error: %s', err);
+  },
+  function () {
+    console.log('Completed');
+  });
+
+// => Next: First: 0,Second: 0
+// => Next: First: 1,Second: 0
+// => Next: First: 1,Second: 1
+// => Next: First: 2,Second: 1
+// => Completed
+
 /* Have staggering intervals */
 var source1 = Rx.Observable.interval(100)
   .map(function (i) { return 'First: ' + i; });

doc/api/core/operators/zip.md

@@ -12,16 +12,41 @@ Merges the specified observable sequences or Promises into one observable sequen
 
 #### Example
 ```js
-/* Using arguments */
+/* Without a result selector */
 var range = Rx.Observable.range(0, 5);
 
 var source = Observable.zip(
-    range,
-    range.skip(1),
-    range.skip(2),
-    function (s1, s2, s3) {
-        return s1 + ':' + s2 + ':' + s3;
-    }
+  range,
+  range.skip(1),
+  range.skip(2)
+);
+
+var subscription = source.subscribe(
+  function (x) {
+    console.log('Next: %s', x);
+  },
+  function (err) {
+    console.log('Error: %s', err);
+  },
+  function () {
+    console.log('Completed');
+  });
+
+// => Next: 0,1,2
+// => Next: 1,2,3
+// => Next: 2,3,4
+// => Completed
+
+/* With a result selector */
+var range = Rx.Observable.range(0, 5);
+
+var source = Observable.zip(
+  range,
+  range.skip(1),
+  range.skip(2),
+  function (s1, s2, s3) {
+    return s1 + ':' + s2 + ':' + s3;
+  }
 );
 
 var subscription = source.subscribe(
@@ -44,24 +69,24 @@ var subscription = source.subscribe(
 var range = Rx.Observable.range(0, 5);
 
 var source = Observable.zip(
-    RSVP.Promise.resolve(0),
-    RSVP.Promise.resolve(1),
-    Rx.Observable.return(2)
-    function (s1, s2, s3) {
-        return s1 + ':' + s2 + ':' + s3;
-    }
+  Promise.resolve(0),
+  Promise.resolve(1),
+  Rx.Observable.return(2)
+  function (s1, s2, s3) {
+    return s1 + ':' + s2 + ':' + s3;
+  }
 );
 
 var subscription = source.subscribe(
-    function (x) {
-        console.log('Next: ' + x);
-    },
-    function (err) {
-        console.log('Error: ' + err);
-    },
-    function () {
-        console.log('Completed');
-    });
+  function (x) {
+    console.log('Next: %s', x);
+  },
+  function (err) {
+    console.log('Error: %s', err);
+  },
+  function () {
+    console.log('Completed');
+  });
 
 // => Next: 0:1:2
 // => Completed

doc/api/core/operators/zipproto.md

@@ -12,6 +12,30 @@ Merges the specified observable sequences or Promises into one observable sequen
 
 #### Example
 ```js
+/* Without a result selector */
+var range = Rx.Observable.range(0, 5);
+
+var source = range.zip(
+  range.skip(1),
+  range.skip(2)
+);
+
+var subscription = source.subscribe(
+  function (x) {
+    console.log('Next: %s', x);
+  },
+  function (err) {
+    console.log('Error: %s', err);
+  },
+  function () {
+    console.log('Completed');
+  });
+
+// => Next: 0,1,2
+// => Next: 1,2,3
+// => Next: 2,3,4
+// => Completed  
+
 /* Using arguments */
 var range = Rx.Observable.range(0, 5);