most - npm Package Compare versions

Comparing version 0.8.0 to 0.8.2

bower.json

 {
   "name": "most",
   "main": "most.js",
-  "version": "0.8.0",
+  "version": "0.8.2",
   "homepage": "https://github.com/cujojs/most",
@@ -6,0 +6,0 @@ "authors": [

docs/api.md

@@ -829,2 +829,9 @@ most.js API
 
+```
+s:               -a-b-c-d-e-f->
+t:               -1-2-3-4-5-6->
+stream:          -s-----t----->
+stream.switch(): -a-b-c-4-5-6->
+```
+
 *TODO: Example*
@@ -837,4 +844,11 @@
 
-Flatten a higher-order stream one level.
+Given a higher-order stream, return a new stream that merges all the inner streams as they arrive.
 
+```
+s:             ---a---b---c---d-->
+t:             -1--2--3--4--5--6->
+stream:        -s------t--------->
+stream.join(): ---a---b--4c-5-d6->
+```
+
 *TODO: Example*
@@ -841,0 +855,0 @@

lib/combinators/join.js

@@ -46,3 +46,3 @@ /** @license MIT License (c) copyright 2010-2014 original author or authors */
 	if(i.done) {
-		return s.length === 1 ? i : stepJoin(replace(endOuter(s[0].stream), 0, s));
+		return s.length === 1 ? i : stepJoin(replace(endOuter(i, s[0].stream), 0, s));
 	}
@@ -77,4 +77,4 @@
 
-function endOuter(stream) {
-	return { stream: stream, i: neverP };
+function endOuter(i, stream) {
+	return { stream: stream, i: disposeOuter(i, stream) };
 }
@@ -95,2 +95,8 @@
 
+function disposeOuter (i, stream) {
+	return when(function () {
+		return neverP;
+	}, stream.dispose(i.time, i.value, i.state));
+}
+
 function disposeInners(t, x, s) {
@@ -97,0 +103,0 @@ return all(map(function(si) {

package.json

 {
   "name": "most",
-  "version": "0.8.0",
+  "version": "0.8.2",
   "description": "Monadic streams",
@@ -5,0 +5,0 @@ "main": "most.js",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

110917

increased by0.45%

Lines of code

2516

increased by0.2%

No dependency changes