@reactive-js/rx - npm Package Compare versions

Comparing version 0.0.6 to 0.0.7

dist/cjs/internal/connect.js

@@ -29,3 +29,3 @@ "use strict";
 }
-exports.connect = (observable, scheduler) => {
+exports.connect = (scheduler) => (observable) => {
     const subscription = disposable_1.createDisposable();
@@ -32,0 +32,0 @@ const subscriber = new AutoDisposingSubscriber(scheduler, subscription);

dist/esm5/internal/connect.js

@@ -27,3 +27,3 @@ import { createDisposable } from "@reactive-js/disposable";
 }
-export const connect = (observable, scheduler) => {
+export const connect = (scheduler) => (observable) => {
     const subscription = createDisposable();
@@ -30,0 +30,0 @@ const subscriber = new AutoDisposingSubscriber(scheduler, subscription);

dist/types/internal/connect.d.ts

 import { DisposableLike } from "@reactive-js/disposable";
+import { OperatorLike } from "@reactive-js/pipe";
 import { SchedulerLike } from "@reactive-js/scheduler";
 import { ObservableLike } from "./interfaces";
-export declare const connect: <T>(observable: ObservableLike<T>, scheduler: SchedulerLike) => DisposableLike;
+export declare const connect: <T>(scheduler: SchedulerLike) => OperatorLike<ObservableLike<T>, DisposableLike>;
 //# sourceMappingURL=connect.d.ts.map

docs/README.md

@@ -31,3 +31,3 @@ [@reactive-js/rx](README.md)
 
-▸ **connect**<**T**>(`observable`: [ObservableLike](interfaces/observablelike.md)‹T›, `scheduler`: SchedulerLike): *DisposableLike*
+▸ **connect**<**T**>(`scheduler`: SchedulerLike): *OperatorLike‹[ObservableLike](interfaces/observablelike.md)‹T›, DisposableLike›*
 
@@ -46,6 +46,5 @@ Safely connects an ObservableLike to a SubscriberLike,
 ------ | ------ |
-`observable` | [ObservableLike](interfaces/observablelike.md)‹T› |
 `scheduler` | SchedulerLike |
 
-**Returns:** *DisposableLike*
+**Returns:** *OperatorLike‹[ObservableLike](interfaces/observablelike.md)‹T›, DisposableLike›*
 
@@ -52,0 +51,0 @@ ___

package.json

 {
   "name": "@reactive-js/rx",
-  "version": "0.0.6",
+  "version": "0.0.7",
   "main": "dist/cjs/index.js",
@@ -41,7 +41,8 @@ "module": "dist/esm5/index.js",
   "dependencies": {
-    "@reactive-js/disposable": "^0.0.6",
-    "@reactive-js/scheduler": "^0.0.6"
+    "@reactive-js/disposable": "^0.0.7",
+    "@reactive-js/scheduler": "^0.0.7"
   },
   "devDependencies": {
-    "@reactive-js/schedulers": "^0.0.6",
+    "@reactive-js/pipe": "^0.0.7",
+    "@reactive-js/schedulers": "^0.0.7",
     "@types/jest": "^24.0.23",
@@ -71,3 +72,3 @@ "jest": "^24.9.0",
   },
-  "gitHead": "de556526ea932ae090f61f71eae15604770ef0a9"
+  "gitHead": "6a380ab10970ac5ef46b6e8599e7ca0f7051c158"
 }

README.md

@@ -37,2 +37,3 @@ # @reactive-js/rx
 import { connect } from "@reactive-js/rx";
+import { pipe } from "@reactive-js/pipe";
 
@@ -43,3 +44,3 @@ const observableSource;
 // Setup a subscription to the observableSource using the platform scheduler
-const subscription = connect(observableSource, platformScheduler);
+const subscription = pipe(observableSource, connect(platformScheduler));
 
@@ -46,0 +47,0 @@ // ...later in the future

src/internal/connect.ts

 import { createDisposable, DisposableLike } from "@reactive-js/disposable";
+import { OperatorLike } from "@reactive-js/pipe";
 import { SchedulerLike } from "@reactive-js/scheduler";
@@ -44,4 +45,5 @@ import { ErrorLike, ObservableLike, SubscriberLike } from "./interfaces";
 export const connect = <T>(
+  scheduler: SchedulerLike,
+): OperatorLike<ObservableLike<T>, DisposableLike> => (
   observable: ObservableLike<T>,
-  scheduler: SchedulerLike,
 ): DisposableLike => {
@@ -48,0 +50,0 @@ const subscription = createDisposable();

test/index.spec.ts

@@ -10,7 +10,10 @@ import {
 
+import { pipe } from "@reactive-js/pipe";
+
 import { SchedulerLike } from "@reactive-js/scheduler";
 
-import { createVirtualTimeScheduler } from "@reactive-js/schedulers";
+import { createVirtualTimeSchedulerResource } from "@reactive-js/schedulers";
 
 import { AbstractSubscriber } from "../src/internal/abstractSubscriber";
+import { ObserverLike } from "../dist/types";
 
@@ -39,6 +42,12 @@ class MockSubscriber<T> extends AbstractSubscriber<T> {
       expect(() =>
-        connect(seriallyCallsNextOnSubscribe, createVirtualTimeScheduler()),
+        pipe(
+          seriallyCallsNextOnSubscribe,
+          connect(createVirtualTimeSchedulerResource()),
+        ),
       ).toThrow();
       expect(() =>
-        connect(seriallyCallsCompleteOnSubscribe, createVirtualTimeScheduler()),
+        pipe(
+          seriallyCallsCompleteOnSubscribe,
+          connect(createVirtualTimeSchedulerResource()),
+        ),
       ).toThrow();
@@ -49,5 +58,5 @@ });
       const observable = createObservable(observer => observer.complete());
-      const scheduler = createVirtualTimeScheduler();
+      const scheduler = createVirtualTimeSchedulerResource();
 
-      const subscription = connect(observable, scheduler);
+      const subscription = pipe(observable, connect(scheduler));
       expect(subscription.isDisposed).toBeFalsy();
@@ -62,3 +71,3 @@
     test("completes the subscriber if onSubscribe throws", () => {
-      const scheduler = createVirtualTimeScheduler();
+      const scheduler = createVirtualTimeSchedulerResource();
       const subscriber = new MockSubscriber(scheduler);
@@ -77,8 +86,9 @@ const cause = new Error();
     test("disposes the returned onSubscribe dispsoable when the returned subscription is disposed", () => {
-      const scheduler = createVirtualTimeScheduler();
+      const scheduler = createVirtualTimeSchedulerResource();
       const disposable = createDisposable();
 
-      const subscription = connect(
-        createObservable(_ => disposable),
-        scheduler,
+      const subscription = pipe(
+        (_: ObserverLike<unknown>) => disposable,
+        createObservable,
+        connect(scheduler),
       );
@@ -102,3 +112,3 @@ scheduler.run();
 
-      const scheduler = createVirtualTimeScheduler();
+      const scheduler = createVirtualTimeSchedulerResource();
       const subscriber = new MockSubscriber(scheduler);
@@ -118,3 +128,3 @@ subject.subscribe(subscriber);
 
-      const scheduler = createVirtualTimeScheduler();
+      const scheduler = createVirtualTimeSchedulerResource();
       const subscriber = new MockSubscriber(scheduler);
@@ -141,3 +151,3 @@ subject.subscribe(subscriber);
 
-      const scheduler = createVirtualTimeScheduler();
+      const scheduler = createVirtualTimeSchedulerResource();
       const subscriber = new MockSubscriber(scheduler);
@@ -144,0 +154,0 @@ subject.subscribe(subscriber);

No alert changes

Improved metrics

Total package byte prevSize

600405

increased by662.15%

Number of package files

112

increased by51.35%

Lines of code

2070

increased by60.84%

Number of lines in readme file

54

increased by1.89%

Worsened metrics

Dev dependency count

5

increased by25%

Dependency changes

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

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

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

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

• Updated@reactive-js/disposable@^0.0.7

• Updated@reactive-js/scheduler@^0.0.7