most-subject - npm Package Compare versions

Comparing version 5.1.0 to 5.2.0

CHANGELOG.md

@@ -0,1 +1,11 @@
+<a name="5.1.0"></a>
+# [5.1.0](https://github.com/mostjs-community/most-subject/compare/v5.0.0...v5.1.0) (2016-11-10)
+
+
+### Bug Fixes
+
+* **error:** fix type signature ([4534e42](https://github.com/mostjs-community/most-subject/commit/4534e42))
+
+
+
 <a name="5.0.0"></a>
@@ -2,0 +12,0 @@ # [5.0.0](https://github.com/mostjs-community/most-subject/compare/v4.1.1...v5.0.0) (2016-11-09)

lib/commonjs/sources/HoldSubjectSource.js

@@ -7,3 +7,3 @@ "use strict";
 };
-var defaultScheduler_1 = require('most/lib/scheduler/defaultScheduler');
+var most_1 = require('most');
 var multicast_1 = require('@most/multicast');
@@ -36,3 +36,3 @@ var prelude_1 = require('@most/prelude');
     for (var i = 0; i < length; ++i) {
-        sink.event(defaultScheduler_1.default.now(), buffer[i]);
+        sink.event(most_1.defaultScheduler.now(), buffer[i]);
     }
@@ -39,0 +39,0 @@ }

lib/commonjs/subjects/async/index.js

@@ -8,4 +8,2 @@ "use strict";
 var most_1 = require('most');
-var defaultScheduler_1 = require('most/lib/scheduler/defaultScheduler');
-var PropagateTask_1 = require('most/lib/scheduler/PropagateTask');
 var multicast_1 = require('@most/multicast');
@@ -26,11 +24,11 @@ function async() {
     AsyncSubject.prototype.next = function (value) {
-        defaultScheduler_1.default.asap(PropagateTask_1.default.event(value, this.source));
+        most_1.defaultScheduler.asap(most_1.PropagateTask.event(value, this.source));
         return this;
     };
     AsyncSubject.prototype.error = function (err) {
-        defaultScheduler_1.default.asap(PropagateTask_1.default.error(err, this.source));
+        most_1.defaultScheduler.asap(most_1.PropagateTask.error(err, this.source));
         return this;
     };
     AsyncSubject.prototype.complete = function (value) {
-        defaultScheduler_1.default.asap(PropagateTask_1.default.end(value, this.source));
+        most_1.defaultScheduler.asap(most_1.PropagateTask.end(value, this.source));
         return this;
@@ -37,0 +35,0 @@ };

lib/commonjs/subjects/sync/index.js

@@ -8,3 +8,2 @@ "use strict";
 var most_1 = require('most');
-var defaultScheduler_1 = require('most/lib/scheduler/defaultScheduler');
 var multicast_1 = require('@most/multicast');
@@ -25,11 +24,11 @@ function sync() {
     SyncSubject.prototype.next = function (value) {
-        this.source.event(defaultScheduler_1.default.now(), value);
+        this.source.event(most_1.defaultScheduler.now(), value);
         return this;
     };
     SyncSubject.prototype.error = function (err) {
-        this.source.error(defaultScheduler_1.default.now(), err);
+        this.source.error(most_1.defaultScheduler.now(), err);
         return this;
     };
     SyncSubject.prototype.complete = function (value) {
-        this.source.end(defaultScheduler_1.default.now(), value);
+        this.source.end(most_1.defaultScheduler.now(), value);
         return this;
@@ -36,0 +35,0 @@ };

lib/es2015/sources/HoldSubjectSource.js

@@ -1,2 +0,2 @@
-import defaultScheduler from 'most/lib/scheduler/defaultScheduler';
+import { defaultScheduler } from 'most';
 import { MulticastSource } from '@most/multicast';
@@ -3,0 +3,0 @@ import { append, drop } from '@most/prelude';

lib/es2015/subjects/async/index.js

@@ -1,4 +0,2 @@
-import { Stream, never } from 'most';
-import scheduler from 'most/lib/scheduler/defaultScheduler';
-import PropagateTask from 'most/lib/scheduler/PropagateTask';
+import { Stream, never, defaultScheduler, PropagateTask } from 'most';
 import { MulticastSource } from '@most/multicast';
@@ -16,11 +14,11 @@ export function async() {
     next(value) {
-        scheduler.asap(PropagateTask.event(value, this.source));
+        defaultScheduler.asap(PropagateTask.event(value, this.source));
         return this;
     }
     error(err) {
-        scheduler.asap(PropagateTask.error(err, this.source));
+        defaultScheduler.asap(PropagateTask.error(err, this.source));
         return this;
     }
     complete(value) {
-        scheduler.asap(PropagateTask.end(value, this.source));
+        defaultScheduler.asap(PropagateTask.end(value, this.source));
         return this;
@@ -27,0 +25,0 @@ }

lib/es2015/subjects/sync/index.js

@@ -1,3 +0,2 @@
-import { Stream, never } from 'most';
-import scheduler from 'most/lib/scheduler/defaultScheduler';
+import { Stream, never, defaultScheduler as scheduler } from 'most';
 import { MulticastSource } from '@most/multicast';
@@ -4,0 +3,0 @@ export function sync() {

package.json

 {
   "name": "most-subject",
-  "version": "5.1.0",
+  "version": "5.2.0",
   "description": "Subjects for most.js",
@@ -64,4 +64,4 @@ "main": "lib/commonjs/index.js",
     "@most/prelude": "^1.4.1",
-    "most": "^1.0.5"
+    "most": "^1.1.0"
   }
 }

src/sources/HoldSubjectSource.ts

@@ -1,3 +0,2 @@
-import { Sink, Source } from 'most';
-import defaultScheduler from 'most/lib/scheduler/defaultScheduler';
+import { Sink, Source, defaultScheduler } from 'most';
 import { MulticastSource } from '@most/multicast';
@@ -4,0 +3,0 @@ import { append, drop } from '@most/prelude';

src/subjects/async/index.ts

@@ -1,4 +0,2 @@
-import { Stream, Source, Sink, never } from 'most';
-import scheduler from 'most/lib/scheduler/defaultScheduler';
-import PropagateTask from 'most/lib/scheduler/PropagateTask';
+import { Stream, Source, Sink, never, defaultScheduler, PropagateTask } from 'most';
 import { MulticastSource } from '@most/multicast';
@@ -24,3 +22,3 @@
   public next (value: T) {
-    scheduler.asap(PropagateTask.event(value, this.source));
+    defaultScheduler.asap(PropagateTask.event(value, this.source));
     return this;
@@ -30,3 +28,3 @@ }
   public error <Err extends Error> (err: Err) {
-    scheduler.asap(PropagateTask.error(err, this.source));
+    defaultScheduler.asap(PropagateTask.error(err, this.source));
     return this;
@@ -36,5 +34,5 @@ }
   public complete (value?: T) {
-    scheduler.asap(PropagateTask.end(value as T, this.source));
+    defaultScheduler.asap(PropagateTask.end(value as T, this.source));
     return this;
   }
 }

src/subjects/sync/index.ts

@@ -1,3 +0,2 @@
-import { Stream, Source, Sink, never } from 'most';
-import scheduler from 'most/lib/scheduler/defaultScheduler';
+import { Stream, Source, Sink, never, defaultScheduler as scheduler } from 'most';
 import { MulticastSource } from '@most/multicast';
@@ -4,0 +3,0 @@

test/tsconfig.json

@@ -17,3 +17,2 @@ {
   "include": [
-    "../custom-typings/most.d.ts",
     "../src/**/*.ts",
@@ -20,0 +19,0 @@ "./**/*.ts"

tsconfig-commonjs.json

@@ -19,5 +19,4 @@ {
   "files": [
-    "./custom-typings/most.d.ts",
     "src/index.ts"
   ]
 }

tsconfig.json

@@ -19,5 +19,4 @@ {
   "files": [
-    "./custom-typings/most.d.ts",
     "src/index.ts"
   ]
 }

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

Worsened metrics

Total package byte prevSize

59810

decreased by-20.34%

Number of package files

98

decreased by-16.24%

Lines of code

1009

decreased by-20.92%

Dependency changes

• Updatedmost@^1.1.0