Comparing version 1.0.6 to 1.0.7
@@ -408,3 +408,3 @@ import { RNId } from './types/RNId'; | ||
initialValue: T, | ||
predicate: (e: T) => boolean | ||
predicate: (srcValue: T, srcIndex: number, index: number) => boolean, | ||
): RN<T> { | ||
@@ -488,6 +488,2 @@ return filter<T>( initialValue, predicate )( this ); | ||
} |
@@ -46,3 +46,3 @@ import { Subscriber } from './types/Subscriber'; | ||
debounce(time: number): RN<T>; | ||
filter(initialValue: T, predicate: (e: T) => boolean): RN<T>; | ||
filter(initialValue: T, predicate: (srcValue: T, srcIndex: number, index: number) => boolean): RN<T>; | ||
flatMap<U>(fn: (srcValue: T, srcIndex: number, index: number) => RN<U>): RN<U>; | ||
@@ -49,0 +49,0 @@ map<U>(fn: (srcValue: T, srcIndex: number, index: number) => U): RN<U>; |
@@ -1,3 +0,2 @@ | ||
export { RN } from './src/internal/RN'; | ||
export { combine, merge, fromEvent, fromPromise, fromObservable, interval, manual, toObservable } from './src/RN'; | ||
export { RN, combine, merge, fromEvent, fromPromise, fromObservable, interval, manual, toObservable } from './src/RN'; | ||
export { debounce, filter, flatMap, map, mapTo, pairwise, pluck, scan, skipUnchanged, skip, skipWhile, switchMap, take, takeWhile, withLatest } from './src/operators'; |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
var RN_1 = require("./src/internal/RN"); | ||
var RN_1 = require("./src/RN"); | ||
exports.RN = RN_1.RN; | ||
var RN_2 = require("./src/RN"); | ||
exports.combine = RN_2.combine; | ||
exports.merge = RN_2.merge; | ||
exports.fromEvent = RN_2.fromEvent; | ||
exports.fromPromise = RN_2.fromPromise; | ||
exports.fromObservable = RN_2.fromObservable; | ||
exports.interval = RN_2.interval; | ||
exports.manual = RN_2.manual; | ||
exports.toObservable = RN_2.toObservable; | ||
exports.combine = RN_1.combine; | ||
exports.merge = RN_1.merge; | ||
exports.fromEvent = RN_1.fromEvent; | ||
exports.fromPromise = RN_1.fromPromise; | ||
exports.fromObservable = RN_1.fromObservable; | ||
exports.interval = RN_1.interval; | ||
exports.manual = RN_1.manual; | ||
exports.toObservable = RN_1.toObservable; | ||
var operators_1 = require("./src/operators"); | ||
@@ -15,0 +14,0 @@ exports.debounce = operators_1.debounce; |
@@ -46,3 +46,3 @@ import { Subscriber } from './types/Subscriber'; | ||
debounce(time: number): RN<T>; | ||
filter(initialValue: T, predicate: (e: T) => boolean): RN<T>; | ||
filter(initialValue: T, predicate: (srcValue: T, srcIndex: number, index: number) => boolean): RN<T>; | ||
flatMap<U>(fn: (srcValue: T, srcIndex: number, index: number) => RN<U>): RN<U>; | ||
@@ -49,0 +49,0 @@ map<U>(fn: (srcValue: T, srcIndex: number, index: number) => U): RN<U>; |
@@ -1,4 +0,3 @@ | ||
export { RN } from './src/internal/RN'; | ||
export { | ||
RN, | ||
combine, | ||
@@ -5,0 +4,0 @@ merge, |
{ | ||
"scripts": { | ||
"build": "tsc" | ||
}, | ||
"name": "rnjs", | ||
"version": "1.0.6", | ||
"version": "1.0.7", | ||
"description": "Reactive Programming Library for TypeScript/JavaScript", | ||
"main": "dist/index.js", | ||
"types": "dist/index.d.ts", | ||
"scripts": { | ||
"build": "tsc", | ||
"test": "echo \"Error: no test specified\" && exit 1" | ||
}, | ||
"repository": { | ||
@@ -31,7 +30,9 @@ "type": "git", | ||
"devDependencies": { | ||
"typescript": "^3.2.2" | ||
"rxjs": "^6.3.3", | ||
"ts-loader": "^5.3.1", | ||
"typescript": "^3.2.2", | ||
"webpack": "^4.27.1", | ||
"webpack-cli": "^3.1.2" | ||
}, | ||
"dependencies": { | ||
"rxjs": "^6.3.3" | ||
} | ||
"dependencies": {} | ||
} |
@@ -80,3 +80,3 @@ # RN | ||
* Bainomugisha, Engineer, et al. "A survey on reactive programming." ACM Computing Surveys (CSUR) 45.4 (2013): 52. | ||
* all tasks are processed by priority-queue | ||
* all tasks are processed by the priority-queue | ||
@@ -86,4 +86,4 @@ | ||
* initial value | ||
* every RN has an initial value | ||
* you can get the current value by `value` property | ||
* all RNs have initial values | ||
* you can get the current value with `value` property | ||
(like `BehaviorSubject` in RxJS) | ||
@@ -108,8 +108,8 @@ | ||
* hot-RN(Observable) only | ||
* no cold/hot conversions are needed | ||
* all subscriber of an RN gets the same value at the same time | ||
* no cold/hot conversion is necessary | ||
* all subscribers of the RN receive the same value at the same time | ||
* compatiblity with RxJS | ||
* interconversion methods (toObservable, fromObservable) | ||
* same API of subscribe as RxJS | ||
* mutual conversion methods (toObservable, fromObservable) | ||
* the same `subscribe` API as RxJS | ||
* RN can be passed to Angular async pipe | ||
@@ -648,1 +648,10 @@ without conversion to RxJS Observable | ||
``` | ||
## ToDo | ||
* GUI application for generating RN code from data-flow graph | ||
* add operators | ||
* | ||
@@ -389,3 +389,3 @@ import { RNId } from './types/RNId'; | ||
initialValue: T, | ||
predicate: (e: T) => boolean | ||
predicate: (srcValue: T, srcIndex: number, index: number) => boolean, | ||
): RN<T> { | ||
@@ -469,6 +469,2 @@ return filter<T>( initialValue, predicate )( this ); | ||
} | ||
@@ -475,0 +471,0 @@ |
@@ -5,3 +5,3 @@ { | ||
"target": "ES2015", /* Specify ECMAScript target version: 'ES3' (default), 'ES5', 'ES2015', 'ES2016', 'ES2017','ES2018' or 'ESNEXT'. */ | ||
"module": "commonjs", /* Specify module code generation: 'none', 'commonjs', 'amd', 'system', 'umd', 'es2015', or 'ESNext'. */ | ||
"module": "es2015", /* Specify module code generation: 'none', 'commonjs', 'amd', 'system', 'umd', 'es2015', or 'ESNext'. */ | ||
"lib": [ "dom", "es7" ], | ||
@@ -41,3 +41,3 @@ // "lib": [], /* Specify library files to be included in the compilation. */ | ||
/* Module Resolution Options */ | ||
// "moduleResolution": "node", /* Specify module resolution strategy: 'node' (Node.js) or 'classic' (TypeScript pre-1.6). */ | ||
"moduleResolution": "node", /* Specify module resolution strategy: 'node' (Node.js) or 'classic' (TypeScript pre-1.6). */ | ||
// "baseUrl": "./", /* Base directory to resolve non-absolute module names. */ | ||
@@ -44,0 +44,0 @@ // "paths": {}, /* A series of entries which re-map imports to lookup locations relative to the 'baseUrl'. */ |
No tests
QualityPackage does not have any tests. This is a strong signal of a poorly maintained or low quality package.
Found 1 instance in 1 package
248358
0
254
6450
1
654
5
- Removedrxjs@^6.3.3
- Removedrxjs@6.6.7(transitive)
- Removedtslib@1.14.1(transitive)