@tanbo/stream - npm Package Compare versions

Comparing version 0.0.8 to 0.0.9

operators/distinct-until-changed.js

@@ -7,5 +7,5 @@ import { Observable } from '../core/_api';
     return function (source) {
-        let lastValue = {};
-        let isFirst = true;
         return new Observable(subscriber => {
+            let lastValue = {};
+            let isFirst = true;
             return source.subscribe({
@@ -12,0 +12,0 @@ next(value) {

operators/share.d.ts

 import { Operator } from '../core/_api';
+/**
+ * 让多个订阅共享同一个数据源，而不是创建新的
+ */
 export declare function share<T>(): Operator<T, T>;

operators/share.js

 import { Subject } from '../core/_api';
+/**
+ * 让多个订阅共享同一个数据源，而不是创建新的
+ */
 export function share() {
@@ -3,0 +6,0 @@ return function (source) {

operators/skip.js

@@ -8,4 +8,4 @@ import { Observable } from '../core/_api';
     return function (source) {
-        let i = 0;
         return new Observable(subscriber => {
+            let i = 0;
             const subscribe = {
@@ -12,0 +12,0 @@ next(value) {

operators/take.js

@@ -8,4 +8,4 @@ import { Observable } from '../core/_api';
     return function (source) {
-        let i = 0;
         return new Observable(subscriber => {
+            let i = 0;
             const obs = {
@@ -12,0 +12,0 @@ next(value) {

package.json

 {
   "name": "@tanbo/stream",
-  "version": "0.0.8",
+  "version": "0.0.9",
   "description": "A data stream lib",
@@ -5,0 +5,0 @@ "main": "./public-api.js",

No alert changes

Improved metrics

Total package byte prevSize

53645

increased by0.32%

Lines of code

1186

increased by0.51%

No dependency changes