Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More →
Socket
Sign inDemoInstall
Socket
Sign inDemoInstall

rdataflow

Package Overview
Dependencies
Maintainers
1
Versions
3
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

rdataflow - npm Package Compare versions

Comparing version 1.0.2 to 1.0.3

LICENSE.txt
README.md

14

package.json
{
"author": {
"email": "ops@rivethealth.com",
"name": "Rivet",
"url": "https://rivethealth.com"
},
"bugs": {

@@ -17,10 +22,7 @@ "url": "https://github.com/rivethealth/rdataflow-js/issues"

"homepage": "https://github.com/rivethealth/rdataflow-js",
"keywords": ["dataflow"],
"license": "MIT",
"name": "rdataflow",
"author": {
"email": "ops@rivethealth.com",
"name": "Rivet",
"url": "https://rivethealth.com"
},
"version": "1.0.2"
"repository": "rivethealth/rdataflow-js",
"version": "1.0.3"
}

16

src/calc.ts

@@ -48,3 +48,3 @@ import { Equal } from "./equal";

private readonly debugInfo: DebugInfo,
private readonly equals: Equal<T> = Equal.identity()
private readonly equals: Equal<T> = Equal.identity(),
) {

@@ -73,3 +73,3 @@ this.resultFn = () => Result.run(fn);

},
this.debugInfo
this.debugInfo,
);

@@ -122,3 +122,3 @@

console.log(
`INVALIDATED\n\t${this.debugInfo.position}\nBY\n\t${debugInfo.position}`
`INVALIDATED\n\t${this.debugInfo.position}\nBY\n\t${debugInfo.position}`,
);

@@ -199,3 +199,3 @@ }

debug = DebugInfo.capture(2),
equals?: Equal<T>
equals?: Equal<T>,
): CalculatedState<T> {

@@ -208,3 +208,3 @@ return new CalculatedState(new CalculatedObservable(f, debug, equals));

debug = DebugInfo.capture(2),
equals?: Equal<T>
equals?: Equal<T>,
): T {

@@ -216,3 +216,3 @@ return calc(f, debug, equals).value;

f: () => State<T>,
debug = DebugInfo.capture(2)
debug = DebugInfo.capture(2),
): CalculatedState<T> {

@@ -228,3 +228,3 @@ const state = calc(f, debug);

fn: () => void,
debug = DebugInfo.capture(2)
debug = DebugInfo.capture(2),
): Reaction {

@@ -239,4 +239,4 @@ return store(

}
}, debug)
}, debug),
);
}

4

src/collection.spec.ts

@@ -15,4 +15,4 @@ import "jest";

return n.value + 1;
})
)
}),
),
);

@@ -19,0 +19,0 @@

2

src/collection.ts

@@ -16,3 +16,3 @@ import { calc } from "./calc";

fn: (a: State<A>, index: State<number>, key: K) => State<B>,
keyFn: (a: A) => K = (a: A) => <K>(<unknown>a)
keyFn: (a: A) => K = (a: A) => <K>(<unknown>a),
): (a: State<A[]>) => State<B[]> {

@@ -19,0 +19,0 @@ return (array) => {

6

src/const.ts

@@ -23,3 +23,3 @@ import { Equal } from "./equal";

},
this.debugInfo
this.debugInfo,
);

@@ -44,3 +44,3 @@ }

return new ConstState(
new ConstStateObservable(new Result.Error(error), debugInfo)
new ConstStateObservable(new Result.Error(error), debugInfo),
);

@@ -52,4 +52,4 @@ }

return new ConstState(
new ConstStateObservable(new Result.Value(value), debugInfo)
new ConstStateObservable(new Result.Value(value), debugInfo),
);
}

4

src/equal.ts

@@ -30,7 +30,7 @@ export interface Equal<T> {

[K in keyof T]?: Equal<T[K]>;
}
},
): Equal<T> {
return (a: T, b: T) => {
return Object.entries(properties).every(([key, equal]: [any, any]) =>
equal(a[<keyof T>key], b[<keyof T>key])
equal(a[<keyof T>key], b[<keyof T>key]),
);

@@ -37,0 +37,0 @@ };

2

src/observable.spec.ts

@@ -48,3 +48,3 @@ import "jest";

debounceTime(0),
tap((a) => console.log("VALUE: ", a))
tap((a) => console.log("VALUE: ", a)),
);

@@ -51,0 +51,0 @@

8

src/observable.ts

@@ -21,3 +21,3 @@ import { Equal } from "./equal";

const UNOBSERVED_RESULT: Result<never> = new Result.Error(
new UnobservedError()
new UnobservedError(),
);

@@ -43,3 +43,3 @@

private readonly observable: RxObservable<T>,
private readonly debugInfo: DebugInfo
private readonly debugInfo: DebugInfo,
) {}

@@ -74,3 +74,3 @@

},
this.debugInfo
this.debugInfo,
);

@@ -173,3 +173,3 @@ private subscription_: RxUnsubscribable | undefined;

export function rxToState<T>(
observable: RxObservable<T>
observable: RxObservable<T>,
): State<T | undefined> {

@@ -176,0 +176,0 @@ const debugInfo = DebugInfo.capture(2);

10

src/property.ts

@@ -18,3 +18,3 @@ import { Equal } from "./equal";

private readonly first: Property<any>,
private readonly second: Property<T>
private readonly second: Property<T>,
) {}

@@ -30,3 +30,3 @@

private readonly key: string | symbol,
private readonly create: () => T
private readonly create: () => T,
) {}

@@ -52,3 +52,3 @@

Symbol("STATE_INFO"),
() => ({})
() => ({}),
);

@@ -71,3 +71,3 @@

const keyProperty = new ObjectProperty(key, () =>
calc<T>(getter, undefined, equals)
calc<T>(getter, undefined, equals),
);

@@ -91,3 +91,3 @@

const keyProperty = new ObjectProperty(key, () =>
WriteableState.value<T>(value, equals)
WriteableState.value<T>(value, equals),
);

@@ -94,0 +94,0 @@

2

src/util.ts

@@ -20,3 +20,3 @@ import { Equal } from "./equal";

private readonly lifecycle: ManagerLifecycle,
private readonly debugInfo: DebugInfo
private readonly debugInfo: DebugInfo,
) {

@@ -23,0 +23,0 @@ this.equals = Result.equal(valueEquals);

12

src/write.ts

@@ -42,4 +42,4 @@ import { Equal } from "./equal";

equals,
DebugInfo.capture(2)
)
DebugInfo.capture(2),
),
);

@@ -53,4 +53,4 @@ }

equals,
DebugInfo.capture(2)
)
DebugInfo.capture(2),
),
);

@@ -67,3 +67,3 @@ }

private readonly equals: Equal<T>,
private readonly debugInfo: DebugInfo
private readonly debugInfo: DebugInfo,
) {

@@ -86,3 +86,3 @@ this.store = new Manager(

},
this.debugInfo
this.debugInfo,
);

@@ -89,0 +89,0 @@ }

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

About

Packages

npm

Go

Maven

PyPI

Rubygems

Stay in touch

Get open source security insights delivered straight into your inbox.

  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc