@sanity/observable - npm Package Compare versions

Comparing version 0.99.0 to 0.102.0-next

lib/SanityObservable.js

@@ -9,26 +9,56 @@ 'use strict';
 
-var _require3 = require('rxjs/observable/from'),
-    from = _require3.from;
+var _require3 = require('rxjs/observable/forkJoin'),
+    forkJoin = _require3.forkJoin;
 
-var _require4 = require('rxjs/operator/map'),
-    map = _require4.map;
+var _require4 = require('rxjs/observable/from'),
+    from = _require4.from;
 
-var _require5 = require('rxjs/operator/filter'),
-    filter = _require5.filter;
+var _require5 = require('rxjs/operator/map'),
+    map = _require5.map;
 
-var _require6 = require('rxjs/operator/reduce'),
-    reduce = _require6.reduce;
+var _require6 = require('rxjs/operator/filter'),
+    filter = _require6.filter;
 
-var _require7 = require('rxjs/operator/scan'),
-    scan = _require7.scan;
+var _require7 = require('rxjs/operator/reduce'),
+    reduce = _require7.reduce;
 
-var _require8 = require('rxjs/operator/mergeMap'),
-    mergeMap = _require8.mergeMap;
+var _require8 = require('rxjs/operator/scan'),
+    scan = _require8.scan;
 
-var _require9 = require('rxjs/operator/concatMap'),
-    concatMap = _require9.concatMap;
+var _require9 = require('rxjs/operator/first'),
+    first = _require9.first;
 
-var _require10 = require('rxjs/operator/toPromise'),
-    toPromise = _require10.toPromise;
+var _require10 = require('rxjs/operator/debounceTime'),
+    debounceTime = _require10.debounceTime;
 
+var _require11 = require('rxjs/operator/distinctUntilChanged'),
+    distinctUntilChanged = _require11.distinctUntilChanged;
+
+var _require12 = require('rxjs/operator/takeUntil'),
+    takeUntil = _require12.takeUntil;
+
+var _require13 = require('rxjs/operator/withLatestFrom'),
+    withLatestFrom = _require13.withLatestFrom;
+
+var _require14 = require('rxjs/operator/merge'),
+    merge = _require14.merge;
+
+var _require15 = require('rxjs/operator/share'),
+    share = _require15.share;
+
+var _require16 = require('rxjs/operator/mergeMap'),
+    mergeMap = _require16.mergeMap;
+
+var _require17 = require('rxjs/operator/switchMap'),
+    switchMap = _require17.switchMap;
+
+var _require18 = require('rxjs/operator/do'),
+    _do = _require18._do;
+
+var _require19 = require('rxjs/operator/concatMap'),
+    concatMap = _require19.concatMap;
+
+var _require20 = require('rxjs/operator/toPromise'),
+    toPromise = _require20.toPromise;
+
 /*
@@ -67,5 +97,14 @@ A subset of rxjs that align as closely as possible with the current es-observable spec
   scan: scan,
+  merge: merge,
   flatMap: mergeMap,
+  first: first,
   mergeMap: mergeMap,
+  switchMap: switchMap,
   concatMap: concatMap,
+  share: share,
+  debounceTime: debounceTime,
+  distinctUntilChanged: distinctUntilChanged,
+  withLatestFrom: withLatestFrom,
+  takeUntil: takeUntil,
+  do: _do,
   toPromise: toPromise,
@@ -95,2 +134,12 @@ lift: lift
 
+SanityObservable.forkJoin = function SanityObservableForkJoin() {
+  for (var _len4 = arguments.length, args = Array(_len4), _key4 = 0; _key4 < _len4; _key4++) {
+    args[_key4] = arguments[_key4];
+  }
+
+  return new SanityObservable(function (observer) {
+    return forkJoin.apply(undefined, args).subscribe(observer);
+  });
+};
+
 module.exports = SanityObservable;

package.json

 {
   "name": "@sanity/observable",
   "description": "A small-ish RxJS based Observable implementation for Sanity",
-  "version": "0.99.0",
+  "version": "0.102.0-next",
   "main": "index.js",
   "scripts": {
+    "clean": "rimraf lib",
     "test": "tap --node-arg=--require --node-arg=babel-register test/*.test.js test/**/*.test.js"
@@ -14,6 +15,7 @@ },
     "object-assign": "^4.1.0",
-    "rxjs": "^5.0.1"
+    "rxjs": "5.0.x"
   },
   "devDependencies": {
     "is-observable": "^0.2.0",
+    "rimraf": "^2.5.2",
     "tap": "^8.0.1",
@@ -20,0 +22,0 @@ "zen-observable": "^0.4.0"

src/SanityObservable.js

 const {Observable} = require('rxjs/Observable')
 const {of} = require('rxjs/observable/of')
+const {forkJoin} = require('rxjs/observable/forkJoin')
 const {from} = require('rxjs/observable/from')
@@ -8,3 +9,12 @@ const {map} = require('rxjs/operator/map')
 const {scan} = require('rxjs/operator/scan')
+const {first} = require('rxjs/operator/first')
+const {debounceTime} = require('rxjs/operator/debounceTime')
+const {distinctUntilChanged} = require('rxjs/operator/distinctUntilChanged')
+const {takeUntil} = require('rxjs/operator/takeUntil')
+const {withLatestFrom} = require('rxjs/operator/withLatestFrom')
+const {merge} = require('rxjs/operator/merge')
+const {share} = require('rxjs/operator/share')
 const {mergeMap} = require('rxjs/operator/mergeMap')
+const {switchMap} = require('rxjs/operator/switchMap')
+const {_do} = require('rxjs/operator/do')
 const {concatMap} = require('rxjs/operator/concatMap')
@@ -40,5 +50,14 @@ const {toPromise} = require('rxjs/operator/toPromise')
   scan,
+  merge,
   flatMap: mergeMap,
+  first,
   mergeMap: mergeMap,
+  switchMap: switchMap,
   concatMap: concatMap,
+  share,
+  debounceTime,
+  distinctUntilChanged,
+  withLatestFrom,
+  takeUntil,
+  do: _do,
   toPromise,
@@ -56,2 +75,6 @@ lift
 
+SanityObservable.forkJoin = function SanityObservableForkJoin(...args) {
+  return new SanityObservable(observer => forkJoin(...args).subscribe(observer))
+}
+
 module.exports = SanityObservable

test/exposed-api.test.js

@@ -21,3 +21,4 @@ /* eslint no-shadow: ["error", { "allow": ['t'] }] */
       'of',
-      'from'
+      'from',
+      'forkJoin'
     ])
@@ -45,5 +46,14 @@ t.end()
       'scan',
+      'merge',
       'flatMap',
+      'first',
       'mergeMap',
+      'switchMap',
       'concatMap',
+      'share',
+      'debounceTime',
+      'distinctUntilChanged',
+      'withLatestFrom',
+      'takeUntil',
+      'do',
       'toPromise',
@@ -50,0 +60,0 @@ 'lift',

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

New author

Supply chain risk

A new npm collaborator published a version of the package for the first time. New collaborators are usually benign additions to a project, but do indicate a change to the security surface area of a package.

Found 1 instance in 1 package

Improved metrics

Number of package files

25

increased by8.7%

Lines of code

612

increased by26.45%

Number of medium supply chain risk alerts

0

decreased by-100%

Worsened metrics

Total package byte prevSize

78835

decreased by-34.41%

Dev dependency count

4

increased by33.33%

Dependency changes

• + Addedrxjs@5.0.3(transitive)

• + Addedsymbol-observable@1.2.0(transitive)

• - Removedrxjs@5.5.12(transitive)

• - Removedsymbol-observable@1.0.1(transitive)

• Updatedrxjs@5.0.x