@reactive-js/ix - npm Package Compare versions

Comparing version 0.0.22 to 0.0.23

dist/cjs/index.d.ts

@@ -1,2 +0,2 @@
-export { AsyncIteratorLike, AsyncIteratorResourceLike, StateUpdaterLike, } from "./internal/interfaces";
+export { AsyncIterableLike, AsyncIteratorLike, AsyncIteratorResourceLike, StateUpdaterLike, } from "./internal/interfaces";
 export { createAsyncIteratorResource } from "./internal/createAsyncIterator";
@@ -3,0 +3,0 @@ export { empty } from "./internal/empty";

dist/cjs/internal/createAsyncIterator.d.ts

@@ -1,5 +0,16 @@
-import { ObservableOperatorLike } from "@reactive-js/rx";
+import { MulticastObservableLike, SubjectResourceLike, SubscriberLike, ObservableOperatorLike } from "@reactive-js/rx";
 import { SchedulerLike } from "@reactive-js/scheduler";
 import { AsyncIteratorResourceLike } from "./interfaces";
+export declare class AsyncIteratorResourceImpl<TReq, T> implements AsyncIteratorResourceLike<TReq, T> {
+    readonly disposable: SubjectResourceLike<TReq>;
+    private readonly observable;
+    add: (this: import("@reactive-js/disposable").DelegatingDisposableLike, disposable: import("@reactive-js/disposable").DisposableOrTeardown, ...disposables: import("@reactive-js/disposable").DisposableOrTeardown[]) => any;
+    dispose: (this: import("@reactive-js/disposable").DelegatingDisposableLike) => boolean;
+    remove: (this: import("@reactive-js/disposable").DelegatingDisposableLike, disposable: import("@reactive-js/disposable").DisposableOrTeardown, ...disposables: import("@reactive-js/disposable").DisposableOrTeardown[]) => any;
+    constructor(disposable: SubjectResourceLike<TReq>, observable: MulticastObservableLike<T>);
+    get isDisposed(): boolean;
+    get subscriberCount(): number;
+    dispatch(req: TReq): void;
+    subscribe(subscriber: SubscriberLike<T>): void;
+}
 export declare const createAsyncIteratorResource: <TReq, T>(operator: ObservableOperatorLike<TReq, T>, scheduler: SchedulerLike, replayCount?: number) => AsyncIteratorResourceLike<TReq, T>;
-export declare const createEventEmitter: <T>(replayCount?: number | undefined) => AsyncIteratorResourceLike<T, T>;

dist/cjs/internal/createAsyncIterator.js

@@ -27,2 +27,3 @@ "use strict";
 }
+exports.AsyncIteratorResourceImpl = AsyncIteratorResourceImpl;
 exports.createAsyncIteratorResource = (operator, scheduler, replayCount = 0) => {
@@ -34,6 +35,2 @@ const dispatcher = rx_1.createSubject();
 };
-exports.createEventEmitter = (replayCount) => {
-    const dispatcher = rx_1.createSubject(replayCount);
-    return new AsyncIteratorResourceImpl(dispatcher, dispatcher);
-};
 //# sourceMappingURL=createAsyncIterator.js.map

dist/cjs/internal/identity.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 const createAsyncIterator_1 = require("./createAsyncIterator");
+const rx_1 = require("@reactive-js/rx");
 const instance = {
-    getIXAsyncIterator: (_, replayCount = 0) => createAsyncIterator_1.createEventEmitter(replayCount),
+    getIXAsyncIterator: (_, replayCount = 0) => {
+        const dispatcher = rx_1.createSubject(replayCount);
+        return new createAsyncIterator_1.AsyncIteratorResourceImpl(dispatcher, dispatcher);
+    }
 };
 exports.identity = () => instance;
 //# sourceMappingURL=identity.js.map

dist/esm5/index.d.ts

@@ -1,2 +0,2 @@
-export { AsyncIteratorLike, AsyncIteratorResourceLike, StateUpdaterLike, } from "./internal/interfaces";
+export { AsyncIterableLike, AsyncIteratorLike, AsyncIteratorResourceLike, StateUpdaterLike, } from "./internal/interfaces";
 export { createAsyncIteratorResource } from "./internal/createAsyncIterator";
@@ -3,0 +3,0 @@ export { empty } from "./internal/empty";

dist/esm5/internal/createAsyncIterator.d.ts

@@ -1,5 +0,16 @@
-import { ObservableOperatorLike } from "@reactive-js/rx";
+import { MulticastObservableLike, SubjectResourceLike, SubscriberLike, ObservableOperatorLike } from "@reactive-js/rx";
 import { SchedulerLike } from "@reactive-js/scheduler";
 import { AsyncIteratorResourceLike } from "./interfaces";
+export declare class AsyncIteratorResourceImpl<TReq, T> implements AsyncIteratorResourceLike<TReq, T> {
+    readonly disposable: SubjectResourceLike<TReq>;
+    private readonly observable;
+    add: (this: import("@reactive-js/disposable").DelegatingDisposableLike, disposable: import("@reactive-js/disposable").DisposableOrTeardown, ...disposables: import("@reactive-js/disposable").DisposableOrTeardown[]) => any;
+    dispose: (this: import("@reactive-js/disposable").DelegatingDisposableLike) => boolean;
+    remove: (this: import("@reactive-js/disposable").DelegatingDisposableLike, disposable: import("@reactive-js/disposable").DisposableOrTeardown, ...disposables: import("@reactive-js/disposable").DisposableOrTeardown[]) => any;
+    constructor(disposable: SubjectResourceLike<TReq>, observable: MulticastObservableLike<T>);
+    get isDisposed(): boolean;
+    get subscriberCount(): number;
+    dispatch(req: TReq): void;
+    subscribe(subscriber: SubscriberLike<T>): void;
+}
 export declare const createAsyncIteratorResource: <TReq, T>(operator: ObservableOperatorLike<TReq, T>, scheduler: SchedulerLike, replayCount?: number) => AsyncIteratorResourceLike<TReq, T>;
-export declare const createEventEmitter: <T>(replayCount?: number | undefined) => AsyncIteratorResourceLike<T, T>;

dist/esm5/internal/createAsyncIterator.js

 import { disposableMixin } from "@reactive-js/disposable";
 import { pipe } from "@reactive-js/pipe";
 import { createSubject, publish, } from "@reactive-js/rx";
-class AsyncIteratorResourceImpl {
+export class AsyncIteratorResourceImpl {
     constructor(disposable, observable) {
@@ -31,6 +31,2 @@ this.disposable = disposable;
 };
-export const createEventEmitter = (replayCount) => {
-    const dispatcher = createSubject(replayCount);
-    return new AsyncIteratorResourceImpl(dispatcher, dispatcher);
-};
 //# sourceMappingURL=createAsyncIterator.js.map

dist/esm5/internal/identity.js

@@ -1,6 +0,10 @@
-import { createEventEmitter } from "./createAsyncIterator";
+import { AsyncIteratorResourceImpl } from "./createAsyncIterator";
+import { createSubject } from "@reactive-js/rx";
 const instance = {
-    getIXAsyncIterator: (_, replayCount = 0) => createEventEmitter(replayCount),
+    getIXAsyncIterator: (_, replayCount = 0) => {
+        const dispatcher = createSubject(replayCount);
+        return new AsyncIteratorResourceImpl(dispatcher, dispatcher);
+    }
 };
 export const identity = () => instance;
 //# sourceMappingURL=identity.js.map

dist/types/index.d.ts

@@ -1,2 +0,2 @@
-export { AsyncIteratorLike, AsyncIteratorResourceLike, StateUpdaterLike, } from "./internal/interfaces";
+export { AsyncIterableLike, AsyncIteratorLike, AsyncIteratorResourceLike, StateUpdaterLike, } from "./internal/interfaces";
 export { createAsyncIteratorResource } from "./internal/createAsyncIterator";
@@ -3,0 +3,0 @@ export { empty } from "./internal/empty";

dist/types/internal/createAsyncIterator.d.ts

@@ -1,6 +0,17 @@
-import { ObservableOperatorLike } from "@reactive-js/rx";
+import { MulticastObservableLike, SubjectResourceLike, SubscriberLike, ObservableOperatorLike } from "@reactive-js/rx";
 import { SchedulerLike } from "@reactive-js/scheduler";
 import { AsyncIteratorResourceLike } from "./interfaces";
+export declare class AsyncIteratorResourceImpl<TReq, T> implements AsyncIteratorResourceLike<TReq, T> {
+    readonly disposable: SubjectResourceLike<TReq>;
+    private readonly observable;
+    add: (this: import("@reactive-js/disposable").DelegatingDisposableLike, disposable: import("@reactive-js/disposable").DisposableOrTeardown, ...disposables: import("@reactive-js/disposable").DisposableOrTeardown[]) => any;
+    dispose: (this: import("@reactive-js/disposable").DelegatingDisposableLike) => boolean;
+    remove: (this: import("@reactive-js/disposable").DelegatingDisposableLike, disposable: import("@reactive-js/disposable").DisposableOrTeardown, ...disposables: import("@reactive-js/disposable").DisposableOrTeardown[]) => any;
+    constructor(disposable: SubjectResourceLike<TReq>, observable: MulticastObservableLike<T>);
+    get isDisposed(): boolean;
+    get subscriberCount(): number;
+    dispatch(req: TReq): void;
+    subscribe(subscriber: SubscriberLike<T>): void;
+}
 export declare const createAsyncIteratorResource: <TReq, T>(operator: ObservableOperatorLike<TReq, T>, scheduler: SchedulerLike, replayCount?: number) => AsyncIteratorResourceLike<TReq, T>;
-export declare const createEventEmitter: <T>(replayCount?: number | undefined) => AsyncIteratorResourceLike<T, T>;
 //# sourceMappingURL=createAsyncIterator.d.ts.map

package.json

 {
   "name": "@reactive-js/ix",
-  "version": "0.0.22",
+  "version": "0.0.23",
   "main": "dist/cjs/index.js",
@@ -41,9 +41,9 @@ "module": "dist/esm5/index.js",
   "dependencies": {
-    "@reactive-js/disposable": "^0.0.22",
-    "@reactive-js/pipe": "^0.0.22",
-    "@reactive-js/rx": "^0.0.22",
-    "@reactive-js/scheduler": "^0.0.22"
+    "@reactive-js/disposable": "^0.0.23",
+    "@reactive-js/pipe": "^0.0.23",
+    "@reactive-js/rx": "^0.0.23",
+    "@reactive-js/scheduler": "^0.0.23"
   },
   "devDependencies": {
-    "@reactive-js/schedulers": "^0.0.22",
+    "@reactive-js/schedulers": "^0.0.23",
     "@types/jest": "^24.0.23",
@@ -74,3 +74,3 @@ "jest": "^24.9.0",
   },
-  "gitHead": "e248139a5eb2c5dd02315ca5743c934d99320ad3"
+  "gitHead": "413ea5c12bc7b59dcc73cab0e33ff3c9acd941f2"
 }

src/index.ts

 export {
+  AsyncIterableLike,
   AsyncIteratorLike,
@@ -3,0 +4,0 @@ AsyncIteratorResourceLike,

src/internal/createAsyncIterator.ts

@@ -14,3 +14,4 @@ import { disposableMixin } from "@reactive-js/disposable";
 
-class AsyncIteratorResourceImpl<TReq, T>
+/** @ignore */
+export class AsyncIteratorResourceImpl<TReq, T>
   implements AsyncIteratorResourceLike<TReq, T> {
@@ -57,9 +58,1 @@ add = disposableMixin.add;
 };
-
-/** @ignore */
-export const createEventEmitter = <T>(
-  replayCount?: number,
-): AsyncIteratorResourceLike<T, T> => {
-  const dispatcher = createSubject(replayCount);
-  return new AsyncIteratorResourceImpl(dispatcher, dispatcher);
-};

src/internal/identity.ts

 import { AsyncIterableLike } from "./interfaces";
 import { SchedulerLike } from "@reactive-js/scheduler";
-import { createEventEmitter } from "./createAsyncIterator";
+import { AsyncIteratorResourceImpl } from "./createAsyncIterator";
+import { createSubject } from "@reactive-js/rx";
 
 const instance = {
-  getIXAsyncIterator: (_: SchedulerLike, replayCount = 0) =>
-    createEventEmitter(replayCount),
+  getIXAsyncIterator: (_: SchedulerLike, replayCount = 0) => {
+    const dispatcher = createSubject(replayCount);
+    return new AsyncIteratorResourceImpl(dispatcher, dispatcher);
+  }
 };
 
 export const identity = <T>(): AsyncIterableLike<T, T> => instance;

No alert changes

Worsened metrics

Total package byte prevSize

689337

decreased by-24.04%

Number of package files

126

decreased by-15.44%

Lines of code

1622

decreased by-27.52%

Dependency changes

• + Added@reactive-js/disposable@0.0.23(transitive)

• + Added@reactive-js/pipe@0.0.23(transitive)

• + Added@reactive-js/rx@0.0.23(transitive)

• + Added@reactive-js/scheduler@0.0.23(transitive)

• - Removed@reactive-js/disposable@0.0.22(transitive)

• - Removed@reactive-js/pipe@0.0.22(transitive)

• - Removed@reactive-js/rx@0.0.22(transitive)

• - Removed@reactive-js/scheduler@0.0.22(transitive)

• Updated@reactive-js/disposable@^0.0.23

• Updated@reactive-js/pipe@^0.0.23

• Updated@reactive-js/rx@^0.0.23

• Updated@reactive-js/scheduler@^0.0.23