Added examples: sequenceEqual, findIndex, reduce, takeLast, skipLast

TODO

@@ -45,10 +45,16 @@ DONE Added examples: sum, any, delayWithSelector
 TODO Add more examples
 TODO Render each stream with a different regular polygon
 TODO Render also the stream completion time marker
+TODO Disambiguate simultaneous marbles
+  Vertically spread them
+  Change example takeLast(1) to takeLast(2)
 >>> v1.1.0
 
 TODO Embeddable rxmarbles
-  - app.coffee 'exports' a function which can be called in <script> in index.html
+  app.coffee 'exports' a function which can be called in <script> in index.html
+>>> v1.1.1
+
+TODO Browser back button selects past operators
 TODO Short text description of each operator, and link to official docs
 >>> v1.2.0
 

src/models/boolean-examples.coffee

@@ -25,17 +25,22 @@ module.exports = {
     "apply": (inputs) -> inputs[0].contains({content:22}, (x,y) -> x.content == y.content)
   }
 
-  # #TODO Debug and fix
-  # "sequenceEqual": {
-  #   "label": "sequenceEqual"
+  # "isEmpty": {
+  #   "label": "isEmpty"
   #   "inputs": [
-  #     [{t:5, d:1}, {t:15, d:2}, {t:25, d:3}, {t:35, d:4}, {t:65, d:5}]
-  #     [{t:2, d:1}, {t:20, d:2}, {t:40, d:3}, {t:70, d:4}, {t:77, d:5}]
+  #     []
   #   ]
-  #   "apply": (inputs) -> inputs[1].sequenceEqual(inputs[0], (x,y) ->
-  #     return 1 if x.content > y.content
-  #     return -1 if x.content < y.content
-  #     return 0
-  #   )
+  #   "apply": (inputs) -> inputs[0].isEmpty()
   # }
+
+  "sequenceEqual": {
+    "label": "sequenceEqual"
+    "inputs": [
+      [{t:5, d:1}, {t:15, d:2}, {t:25, d:3}, {t:35, d:4}, {t:65, d:5}]
+      [{t:2, d:1}, {t:20, d:2}, {t:40, d:3}, {t:70, d:4}, {t:77, d:5}]
+    ]
+    "apply": (inputs) -> inputs[1].sequenceEqual(inputs[0], (x,y) ->
+      return (x.content == y.content)
+    )
+  }
 }

src/models/filter-examples.coffee

@@ -65,11 +65,19 @@ module.exports = {
     "apply": (inputs) -> inputs[0].skip(2)
   }
 
+  "skipLast": {
+    "label": "skipLast(2)"
+    "inputs": [
+      [{t:30, d:1}, {t:40, d:2}, {t:65, d:3}, {t:75, d:4}]
+    ]
+    "apply": (inputs) -> inputs[0].skipLast(2)
+  }
+
   "skipUntil": {
     "label": "skipUntil"
     "inputs": [
       [{t:0, d:1}, {t:10, d:2}, {t:20, d:3}, {t:30, d:4}, {t:40, d:5}, {t:50, d:6}, {t:60, d:7}, {t:70, d:8}, {t:80, d:9}]
-      [{t:47, d:0}, {t:73, d:0}]
+      [{t:45, d:0}, {t:73, d:0}]
     ]
     "apply": (inputs) -> inputs[0].skipUntil(inputs[1])
   }
@@ -82,11 +90,19 @@ module.exports = {
     "apply": (inputs, scheduler) -> inputs[0].take(2, scheduler)
   }
 
+  "takeLast": {
+    "label": "takeLast(1)"
+    "inputs": [
+      [{t:30, d:1}, {t:40, d:2}, {t:65, d:3}, {t:75, d:4}]
+    ]
+    "apply": (inputs) -> inputs[0].takeLast(1)
+  }
+
   "takeUntil": {
     "label": "takeUntil"
     "inputs": [
       [{t:0, d:1}, {t:10, d:2}, {t:20, d:3}, {t:30, d:4}, {t:40, d:5}, {t:50, d:6}, {t:60, d:7}, {t:70, d:8}, {t:80, d:9}]
-      [{t:47, d:0}, {t:73, d:0}]
+      [{t:45, d:0}, {t:73, d:0}]
     ]
     "apply": (inputs) -> inputs[0].takeUntil(inputs[1])
   }

src/models/math-examples.coffee

@@ -1,15 +1,16 @@
 Rx = require 'rx'
 
 module.exports = {
-  "aggregate": {
-    "label": "aggregate((x, y) => x + y)"
-    "inputs": [
-      [{t:5, d:1}, {t:15, d:2}, {t:25, d:3}, {t:35, d:4}, {t:65, d:5}]
-    ]
-    "apply": (inputs) -> inputs[0].aggregate((x, y) ->
-      return {content: x.content + y.content, time: x.time, id: x.id+y.id}
-    )
-  }
+  # A clone of scan?
+  # "aggregate": {
+  #   "label": "aggregate((x, y) => x + y)"
+  #   "inputs": [
+  #     [{t:5, d:1}, {t:15, d:2}, {t:25, d:3}, {t:35, d:4}, {t:65, d:5}]
+  #   ]
+  #   "apply": (inputs) -> inputs[0].aggregate((x, y) ->
+  #     return {content: x.content + y.content, time: x.time, id: x.id+y.id}
+  #   )
+  # }
 
   "average": {
     "label": "average"
@@ -51,6 +52,16 @@ module.exports = {
     )
   }
 
+  "reduce": {
+    "label": "reduce((x, y) => x + y)"
+    "inputs": [
+      [{t:5, d:1}, {t:15, d:2}, {t:25, d:3}, {t:35, d:4}, {t:65, d:5}]
+    ]
+    "apply": (inputs) -> inputs[0].reduce((x, y) ->
+      return {content: x.content + y.content, time: x.time, id: x.id+y.id}
+    )
+  }
+
   "sum": {
     "label": "sum"
     "inputs": [

src/models/transform-examples.coffee

@@ -19,6 +19,14 @@ module.exports = {
     )
   }
 
+  "findIndex": {
+    "label": "findIndex(x => x > 10)"
+    "inputs": [
+      [{t:5, d:2}, {t:15, d:30}, {t:25, d:22}, {t:35, d:5}, {t:45, d:60}, {t:55, d:1}]
+    ]
+    "apply": (inputs, scheduler) -> inputs[0].findIndex((x) -> x.content > 10)
+  }
+
   "map": {
     "label": "map(x => 10 * x)"
     "inputs": [